1

我现在正在用 Python 开发一个聊天服务器。我正在将 pyOpenSSL 应用于我为测试而制作的聊天服务器和虚拟客户端。但是，每当从虚拟客户端向服务器发送文本消息和照片文件时，pyOpenSSL 都会返回严重错误，这促使我停止使用 pyOpenSSL，如下所示。

send_text_message() : exception : [Errno 1] _ssl.c:1309: error:1409F07F:SSL routines:SSL3_WRITE_PENDING:bad write retry
send_text_message() : exception : [Errno 1] _ssl.c:1309: error:1409F07F:SSL routines:SSL3_WRITE_PENDING:bad write retry
send_text_message() : exception : [Errno 1] _ssl.c:1309: error:1409F07F:SSL routines:SSL3_WRITE_PENDING:bad write retry
send_text_message() : exception : [Errno 1] _ssl.c:1309: error:1409F07F:SSL routines:SSL3_WRITE_PENDING:bad write retry
send_text_message() : exception : [Errno 1] _ssl.c:1309: error:1409F07F:SSL routines:SSL3_WRITE_PENDING:bad write retry
send_text_message() : exception : [Errno 1] _ssl.c:1309: error:1409F07F:SSL routines:SSL3_WRITE_PENDING:bad write retry
send_text_message() : exception : [Errno 1] _ssl.c:1309: error:1409F07F:SSL routines:SSL3_WRITE_PENDING:bad write retry

你能告诉我如何解决这个错误吗？还有一个错误导致虚拟客户端死亡。

[client1|chatting1A] socket closed : device_id : client1, client_chatting_id : chatting1A, error : [Errno 10053] 
Exception in thread Thread-8:
Traceback (most recent call last):
  File "C:\Python27\lib\threading.py", line 810, in __bootstrap_inner
    self.run()
  File "C:\Python27\lib\threading.py", line 1082, in run
    self.function(*self.args, **self.kwargs)
  File "D:\temp\uTok1\uTokSocketServer\com\rurusoft\utok\DummyClient.py", line 97, in send_photo_message
    sock.write(message)
  File "C:\Python27\lib\ssl.py", line 172, in write
    return self._sslobj.write(data)
error: [Errno 10054]

如果没有 pyOpenSSL，虚拟客户端和服务器运行良好。应用 pyOpenSSL 会导致意外问题 :(。如果您遇到问题或有解决问题的方法，请告诉我。....如果错误没有解决方案，我宁愿找出其他不使用 OpenSSL 的替代方案。 . 或者您知道任何可以加密/解密机器之间传输的聊天消息和个人文件的替代方案吗？

尽管在写入（发送）数据之前我已经将要发送的数据存储在局部变量中，但每次都会发生错误。


  json_encoded = json.dumps(data)
          while True:
              try:
                  sock.write(json_encoded)
                  break
              except Exception, e:
                  Log.print_log(self.LOG_TAG, 'send_text_message() : exception : %s' % (e))
                  time.sleep(0.05)

已解决： 正如@David Schwartz 评论的那样，以下代码解决了上面的问题。 

    import StringIO
    ...
    io = StringIO.StringIO()
    io.write(json.dumps(data))
    buffer = io.getvalue()
    while True:
        try:
            sock.write(buffer)
            break
    ...

4

1 回答 1

2

OpenSSL 对如何重试写入有非常严格的要求——特别是缓冲区的地址和内容不得更改。当您重试写入时，您必须使用完全相同的缓冲区重试（相同的内容是不够的，当然，绝对禁止不同的内容）。

例如，这是坏的：

ssl_socket.send(send_buffer.getvalue())

由于您没有存储传递给 的值send，如果您需要重试send，如何将相同的值传递给它？不能保证后续调用getvalue将返回相同的结果。如果缓冲区移动，重复此操作可能会生成错误的写入重试，它随时都可能发生。

更新：您的代码不会阻止缓冲区更改。没有不改变反映缓冲区的对象。尝试：

io = StringIO()
json.dumps(data, io)
buffer = io.getvalue()

      while True:
          try:
              sock.write(buffer)
              break

这里，io是缓冲区，并且getvalue只被调用一次。

于 2013-12-21T04:33:04.043 回答