zoukankan      html  css  js  c++  java
  • python socket 收发消息处理粘包问题

    import socket
    import struct
    
        # 初始化socket对象
        def initialSocket(self):
            self.WrtLog('开始连接服务端...')
            try:
                self.tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                self.tcp_client_socket.connect((host, port))  # 连接
                self.WrtLog('连接成功.')
            except Exception as ex1:
                self.WrtLog('连接失败:'+str(ex1))
    
    
        # 监听服务端发送过来的消息
        def fnConnectServer(self):
            self.initialSocket()
            while True:
                msg = self.fnSockGetMsg(self.tcp_client_socket)
                self.WrtLog('服务端发来消息:'+msg)
    
        # 停止
        def fnStopServer(self):
            self.WrtLog('关闭连接...')
            msg = 'qt_quit'
            try:
                self.fnSockSendMsg(self.tcp_client_socket, msg)
                self.tcp_client_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)  # 释放socket对象
                self.WrtLog('释放连接完成')
            except Exception as ex1:
                self.WrtLog(str(ex1))
    
    
        # 发送消息,处理粘包
        def fnSockSendMsg(self, conn, msg):
            msg = msg.encode('utf-8')
            dataHead = struct.pack('i', len(msg))  # 把消息长度打包成固定长度的bytes
            conn.send(dataHead)  # 发送包头
            conn.send(msg)  # 发送消息
    
        # 获取消息,处理粘包
        def fnSockGetMsg(self, conn):
            dataHead = conn.recv(4)  # 先获取包头
            dataLen = struct.unpack('i', dataHead)[0]  # 把包头解包成int类型
            # 开始读取长度为 dataLen 的数据
            recData = b''  # 获取到的消息
            cacheLen = 1024  # 缓冲区大小
            page = dataLen // cacheLen  # 分片
            if page > 0:
                for i in range(page):
                    recData += conn.recv(cacheLen)
                pageEnd = dataLen % cacheLen  # 最后一片
                recData += conn.recv(pageEnd)
            else:
                recData += conn.recv(dataLen)
            msg = recData.decode('utf-8')
            return msg
    
    
    
              
  • 相关阅读:
    Java代码检测工具
    java编程工具
    100-days: The one day
    前端书籍整理
    vue 学习笔记(二)
    从零开始写一个npm包及上传
    Vue Baidu Map 插件的使用
    对数组对象进行过滤
    使用css方法使footer保持在页面的最底部
    判断是第一次打开界面?还是刷新
  • 原文地址:https://www.cnblogs.com/v-dai/p/14958484.html
Copyright © 2011-2022 走看看