这是一个创建于 2379 天前的主题，其中的信息可能已经有所发展或是发生改变。
def recvMessage(self, sockHandle):#读取来自客户端的数据 strings = b"" getNullTime = 0 client = self.dictSocketHandle[sockHandle] num = 1 totalLen = 0 while True: try: print("第"+str(num)+"次读取数据") data = client.recv(1024) # 这儿如果没有拿够 1024 个字节的数据，那么会循环回来拿，但是，如果发现没有数据能拿到，socket 会自动中止，扔出一个异常，代码就结束执行，所以需要 try 一下。 print(len(data)) totalLen += len(data) if len(data) == 0: # 通道断开或者 close 之后，就会一直收到空字符串。 而不是所谓的-1 或者报异常。这个跟 C 和 java 等其他语言很不一样。 self.epollHandle.modify(sockHandle, select.EPOLLHUP | select.EPOLLET) break # print("本次接收到的数据........", data) strings = strings + data getNullTime = 0 except IOError as err: if err.errno == 11: # 发生 Resource temporarily unavailable 错误 错误码为 11，意为：数据尚未准备好，需要等待 if getNullTime >= 7: break else: getNullTime = getNullTime + 1 print("第" + str(getNullTime) + "次获取到空数据，继续尝试中.......") time.sleep(0.1) # getNullTime = getNullTime + 1 # print("第" + str(getNullTime) + "次获取到空数据，继续尝试中.......") else: print("读取数据，未知 IO 错误") self.epollHandle.modify(sockHandle, select.EPOLLHUP | select.EPOLLET) break except: print("未知错误") self.epollHandle.modify(sockHandle, select.EPOLLHUP | select.EPOLLET) break num += 1 print("数据总长度", totalLen) return strings socket 接收数据，数据量稍大，就会断开接收，然后该 socket 会立马再次接收，是什么问题？
第 75 次读取数据 2896 第 76 次读取数据 4344 第 77 次读取数据 7240 第 78 次读取数据 第 1 次获取到空数据，继续尝试中....... 第 79 次读取数据 第 2 次获取到空数据，继续尝试中....... 第 80 次读取数据 第 3 次获取到空数据，继续尝试中....... 第 81 次读取数据 数据总长度 755856 帧为：204 Unknown opcode %#x.12 解析数据帧暂时不用的状态 第 1 次读取数据 10240 第 2 次读取数据 10240 第 3 次读取数据 10240 第 4 次读取数据 10240 第 5 次读取数据 我很确定，此时没有第二个 socket 进来，我只是单纯发了一张 1.8M 的图片而已，小的文件是可以的，不知道为啥！！！求教
 | 1 swulling 2019-05-27 09:01:34 +08:00 via iPhone socket 是流，你这个 recv 返回空，就认为断开…那自然是不行的。 你需要先定义一个应用层协议，比如有起始帧加长度，或者有结束帧。 |
| 2 swulling 2019-05-27 09:06:08 +08:00 via iPhone 另外从你返回 errno 为 11，应该是前面来了非阻塞模式吧，然后加立马加了一个 sleep … 这不还是 block 了么，为啥要用非阻塞模式… |
 | 3 robot1 2019-05-27 09:53:30 +08:00 还是没有弄懂流式协议，所以代码就写不对，建议跟一遍<<UNIX 网络编程>> |
 | 4 firebroo 2019-05-27 09:56:56 +08:00 getNullTime >= 7 这种试探性手法怎么可以用上来。。 |
 | 5 mywaiting 2019-05-27 10:31:46 +08:00  2 虽然我不知道贴主写的是什么鬼，但是我觉得很多讨论 TCP 粘包 的同志正在赶来的路上，然后说贴主写的代码导致粘包了~ [手动狗头~] |
 | 6 cshlxm 2019-05-27 10:32:12 +08:00 def recvdata(self,array): view =memoryview(array).cast('B') while len(view)>0: try: nsent=self.socket.recv_into(view) view = view[nsent:] except socket.error as err: self.logger.error('%s connection error %s ,will reconnect '%(self.ip,err)) self.reconnect() |
| 9 swulling 2019-05-27 10:47:04 +08:00 via iPhone @moxiaowei 非阻塞你加 sleep 和重试就没意义啥，非阻塞读不到就退出是符合预期的，你需要有别的方法之后来继续。 错误的非阻塞远不如正确的阻塞模式。你还是老老实实写阻塞模式，多开几个线程就好了。 |
 | 10 moxiaowei OP 具体代码我扔到了 github 上，有没有大神帮我看看问题到底在哪！ https://github.com/tangwei123/webSocketServer |
 | 12 momocraft 2019-05-27 12:12:20 +08:00 没读到数据凭什么就证明本次接收完毕，要是有人把线拔了呢 |
 | 13 BingoXuan 2019-05-27 13:11:39 +08:00 via Android 1.不需要 sleep，会堵塞 2.不要 epollet，边缘触发一旦你不去处理，epoll 不会重新通知你 |
 | 15 jason94 2019-05-27 13:16:54 +08:00 我们之前 tcp 连接用 tornado 写的，问题比较少。 |
 | 16 liuminghao233 2019-05-27 13:32:49 +08:00 我觉得是 EPOLLET 的问题 没用 python 写过网络程序 但觉得 python+epoll 组合有点奇怪 就像写 golang 用 epoll 一样莫名其妙 用 py，go 就是为了写起来爽一点，要是写得跟 c 一样了，那要来干嘛 我 c++ asio+协程都比这东西爽太多 |
 | 19 sujin190 2019-05-27 15:06:15 +08:00 if getNullTime >= 7 有啥作用，except 出 errno.EWOULDBLOCK, errno.EAGAIN 就表示数据还未准备好需要稍等通知啊，这个很正常啊，网络栈都是组合好数据一次可以读取多个 ip 包的，那么从内核 copy 到用户空间肯定比网络栈处理速度快啊，所以网络栈出 errno.EWOULDBLOCK, errno.EAGAIN 是正常的，没必要重试，下次如果数据准备好了，再调用 epoll 时又会得到通知 |
| 20 BingoXuan 2019-05-27 17:06:38 +08:00 @moxiaowei 我觉得你不应该再重试，如果 errno 为 11 时候，代表着没有新数据了。那么你应该跳出去，等待新 epollin 事件。 对我而言，堵塞 socket 是通过循环不断去读取数据。为了避免线程堵死，会加上 timeout。通过捕捉 timeout 异常和设定重试次数确保堵塞一定事件就放弃，避免线程堵死。当引入了 epoll 就应该变为等待 epoll 事件而不是等待数据。 |
Select Language