实时收发python socket 客户端

问题遇到的现象和发生背景

我通过递归实现了python socket client 实现，但是在记录日志时，出现太多重复的数据，这是什么原因造成的呢

问题相关代码，请勿粘贴截图

import ast
import json
import socket
import time
import random

from settings.record_log import loggers


class Client:

    def __init__(self, host, port, buffer=1024, timeout=10, encoding='utf-8'):
        """
        初始化
        Args:
            host: 建立连接的IP
            port: 建立连接的端口
            buffer: 一次读取的字节大小
            timeout: 超时时间
            encoding: 字符编码格式
        """
        self.host = host
        self.port = port
        self.buffer = buffer
        self.timeout = timeout
        self.encoding = encoding
        self.tcp_client_socket = None

    def connect(self):
        """
        服务端应用程序建立连接
        Returns:

        """

        # 创建tcp客户端套接字
        # 1. AF_INET：表示ipv4
        # 2. SOCK_STREAM: tcp传输协议
        try:
            self.tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
            self.tcp_client_socket.connect((self.host, self.port))
        except socket.error as e:
            print(e)
            self.tcp_client_socket.close()
            time.sleep(5)
            self.connect()

    def send_data(self, send_data: json, frame_number):
        """
        发送数据
        Args:
            send_data: 发送数据体，默认为json格式
            frame_number: 推演结束条件

        Returns:
            无
        """
        # 接收数据进行解码
        send_data = send_data.encode(self.encoding)
        logger = loggers("../logs/socket_log.txt")
        # logger.debug("客户端发送的数据："+ str(send_data))
        if frame_number <= 1000:
            while True:
                self.tcp_client_socket.send(send_data)
                # 接收数据, 这次接收的数据最大字节数是1024
                server_byte_data = self.tcp_client_socket.recv(self.buffer)
                # 对数据进行解码
                try:
                    server_decode_data = ast.literal_eval(server_byte_data.decode(self.encoding))
                    #print("接收服务端的数据为:", server_decode_data, type(server_decode_data))
                    logger.info("接收服务端的数据为:"+str(server_decode_data)+str(type(server_decode_data)))
                except Exception as e:
                    server_decode_data = server_byte_data.decode(self.encoding)
                    # print("接收异常-服务端数据为:", server_decode_data, type(server_decode_data))
                    logger.error("接收异常-服务端数据为:"+str(server_decode_data)+ str(type(server_decode_data)))

                if isinstance(server_decode_data, dict):
                    action_type = server_decode_data.get('action_type')
                    if action_type == "move":
                        server_decode_data['data']['destination']['X'] = random.randint(0, 200)
                        server_decode_data['data']['destination']['Z'] = random.randint(0, 200)
                        self.send_data(self.dict_to_decode(server_decode_data), frame_number)

                    if action_type == "fire":
                        # 该数据结构未知
                        pass

                    if action_type == "observation":
                        pass

        self.close_client()

    def close_client(self):
        """
        关闭套接字
        Returns:

        """
        self.tcp_client_socket.close()

    def dict_to_decode(self, data):
        """
        python字典转字节格式
        Args:
            data: 传入python字典
            
        Returns:
            返回字节格式数据
        """
        data = bytes('{}'.format(data), 'utf-8')
        data = data.decode(self.encoding)
        return data


if __name__ == '__main__':
    c1 = Client('127.0.0.1', 6321)
    c1.connect()
    data = {
        "action_type": "move",
        "room_id": 1,
        "camp_id": 0,
        "data": {
            "obj_id": 102,
            "type": 1,
            "destination": {"X": random.randint(1, 100), "Y": random.randint(1, 100), "Z": random.randint(1, 100)}
        }
    }
    # 字典转字节
    byte_data = c1.dict_to_decode(data)

    c1.send_data(byte_data, 999)

运行结果及报错内容

[2022-06-14 22:32:53] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 58, 'Y': 42, 'Z': 23}}}<class 'dict'>
[2022-06-14 22:32:54] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 179, 'Y': 42, 'Z': 198}}}<class 'dict'>
[2022-06-14 22:32:54] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 179, 'Y': 42, 'Z': 198}}}<class 'dict'>
[2022-06-14 22:32:55] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 41, 'Y': 42, 'Z': 130}}}<class 'dict'>
[2022-06-14 22:32:55] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 41, 'Y': 42, 'Z': 130}}}<class 'dict'>
[2022-06-14 22:32:55] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 41, 'Y': 42, 'Z': 130}}}<class 'dict'>
[2022-06-14 22:32:56] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 14, 'Y': 42, 'Z': 66}}}<class 'dict'>
[2022-06-14 22:32:56] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 14, 'Y': 42, 'Z': 66}}}<class 'dict'>
[2022-06-14 22:32:56] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 14, 'Y': 42, 'Z': 66}}}<class 'dict'>
[2022-06-14 22:32:56] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 14, 'Y': 42, 'Z': 66}}}<class 'dict'>
[2022-06-14 22:32:57] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 195, 'Y': 42, 'Z': 199}}}<class 'dict'>
[2022-06-14 22:32:57] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 195, 'Y': 42, 'Z': 199}}}<class 'dict'>
[2022-06-14 22:32:57] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 195, 'Y': 42, 'Z': 199}}}<class 'dict'>
[2022-06-14 22:32:57] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 195, 'Y': 42, 'Z': 199}}}<class 'dict'>
[2022-06-14 22:32:57] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 195, 'Y': 42, 'Z': 199}}}<class 'dict'>
[2022-06-14 22:32:58] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 85, 'Y': 42, 'Z': 187}}}<class 'dict'>
[2022-06-14 22:32:58] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 85, 'Y': 42, 'Z': 187}}}<class 'dict'>
[2022-06-14 22:32:58] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 85, 'Y': 42, 'Z': 187}}}<class 'dict'>
[2022-06-14 22:32:58] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 85, 'Y': 42, 'Z': 187}}}<class 'dict'>
[2022-06-14 22:32:58] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 85, 'Y': 42, 'Z': 187}}}<class 'dict'>
[2022-06-14 22:32:58] [INFO] 接收服务端的数据为:{'action_type': 'move', 'room_id': 1, 'camp_id': 0, 'data': {'obj_id': 102, 'type': 1, 'destination': {'X': 85, 'Y': 42, 'Z': 187}}}<class 'dict'>

Process finished with exit code -1

我的解答思路和尝试过的方法

我不知道为什么会重复打印这么多次重复的相同时间的日志，这个该如何解决

我想要达到的结果

我想实现客户端实时接收服务端发送过来的数据，处理后再发送给服务端

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

1条回答默认最新

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
zpeien Android领域新星创作者 2022-06-15 15:03
关注
写日志的循环都没有跳出条件，肯定会一直重复输出相同的日志啊，你把这个循环给他一个退出的条件就行了。

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

用python实现socket通讯出现的问题 python tcp/ip websocket
2022-11-06 17:36

回答 2 已采纳 import socket import threading import socketserver nick='' data='' def Notifyall(sentence):
python串口接收文件时间戳收发显示 python qt stm32
2022-04-01 13:36

回答 1 已采纳 1、在是窗口的init now = datetime.now() self.file_name = "{}.txt".format(now.strftime("%Y-%m-%d %H点%M分")
socket只能发送不能接收数据该怎么办？ linux python
2020-09-21 18:29

回答 2 已采纳 socket接收数据相当于要开server，客户端和服务端的处理方式有一点不一样的，打个比方，调试工具开服务端，就相当于它一直在监听，有数据过来就接受，但是客户端是不需要的，发送完关闭就可以了；给你附
详解Python Socket网络编程
2020-12-25 07:04

Socket 是进程间通信的一种方式，它与其他进程间通信的一个主要...本文主要介绍使用Python 进行TCP Socket 网络编程，假设你已经具有初步的网络知识及Python 基本语法知识。 TCP 是一种面向连接的传输层协议，TCP Sock
用Socket写了一个聊天室，为什么客户端看不到实时的收发信息？ c#
2021-03-23 16:04

回答 3 已采纳服务端和客户端的对应关系是“1对N”，服务端在接受到与其连接的某个客户端的消息后，可以将该消息分发给出他以外的其他客户端（多个客户端连接同一个服务端时，服务端显示的连接身份时不一样的，能区分开）。比如
python 向板卡通过 usb hid 发送数据 python stm32
2022-01-05 14:17

回答 1 已采纳我以前做HID设备的时候也发现这个现象，但是单片机那边收到的是正常的，所以就不要管了。
c语言，客户端服务端收发文件 c语言 linux
2021-09-30 00:12

回答 2 已采纳 FILE*f=NULL;f=fopen(buf,'w');if(f){ if(write(msgSock,"ACK",3)==3) { int len=0; while(1)
python socket 客户端与服务端相互发送信息，并且显示接收信息
2023-02-01 16:19

☆程序小黑★的博客然后在客户端输入数据，回车，就可以看到服务端显示消息。同样在服务端输入数据，回车，就可以看到客户端显示消息。功能：客户端与服务端相互发送信息，并且显示接收信。先启动服务器，再启动客户端。
socket服务器与客户端连接2小时以上无数据传输，服务器会主动断开客户端连接 mfc tcp/ip
2021-12-27 08:49

回答 1 已采纳建议你自己写一个心跳,不依赖tcp的那套东西,每隔一分钟或者几十秒发送一次,客户端发送过去,服务端再返回回来,报文弄小点就行,如果超过一定时间双方任意一方没有收到心跳,则断开连接重连.tcp长链接非常
socket网络传输速度很慢的问题 c++ 开发语言
2019-05-06 13:08

回答 2 已采纳在同一台电脑上面可以达到20MB/s 证明大约内部系统支持的速率在 200Mbit/s 左右。在本机上速度很快是因为数据根本没有经过任何网络硬件设备、而是在操作系统内部直接进行了转发。（详查 l
udp怎么实现客户端对客户端收发消息
2016-10-02 02:47

回答 5 已采纳服务器端就用来处理客户端登陆，客户端要同时实现服务端功能用于客户端之间的通信，通信的端口和ip在登陆到公共服务器时上传。客户端登陆后，从公共服务器拿到好友的ip和端口后，直接和好友通信。这种实
Python_socket编程
2023-02-24 22:08

Oayia的博客也有人将socket说成ip+port，ip是用来标识互联网中的一台主机的位置，而port是用来标识这合机器上的一个应用程序，ip地址是配置到网卡上的，而port是应用程序开启的，ip与port的绑定就标识了互联网中独一无二的一个...
我想用python监听服务器下一个端口接收到的数据，在服务器上运行失败 python
2021-03-10 09:47

回答 2 已采纳正常情况【linux centos8测试，win系统复杂，不测试】【你应该把运行过程，启动，连接，测试的流程截图上来】你的程序【运行正常】 1 只能接收一个客户端连接 2 对端【客户端】关闭后
Python Socket网络编程
2022-08-05 23:25

隐身的菜鸟的博客编程的时候，如果要跟某个IP建立连接，我们需要调用操作系统提供的socket API。socket在操作系统层面，可以理解为一个文件。我们可以对这个文件进行一些方法操作。用listen方法，可以让程序作为服务器监听其他客户端...
python socket编程(tcp/udp)
2021-03-27 17:22

焱齿的博客晚点补充一下这篇文章。主要研究一下python下的tcp/udp的使用，包括收发双方；对于tcp的话要考虑循环接收。
没有解决我的问题, 去提问

问题事件

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
创建了问题 6月14日

悬赏问题

¥15 ogg dd trandata 报错
¥15 高缺失率数据如何选择填充方式
¥50 potsgresql15备份问题
¥15 Mac系统vs code使用phpstudy如何配置debug来调试php
¥15 目前主流的音乐软件，像网易云音乐，QQ音乐他们的前端和后台部分是用的什么技术实现的?求解！
¥60 pb数据库修改与连接
¥15 spss统计中二分类变量和有序变量的相关性分析可以用kendall相关分析吗？
¥15 拟通过pc下指令到安卓系统，如果追求响应速度，尽可能无延迟，是不是用安卓模拟器会优于实体的安卓手机？如果是，可以快多少毫秒？
¥20 神经网络Sequential name=sequential, built=False
¥16 Qphython 用xlrd读取excel报错