英文:
Incomplete binary messages received in Python STOMP client
问题
我正在尝试在两个Python STOMP客户端之间交换二进制消息。
消息发送和接收没有问题。但是，接收方总是丢失几个字节（似乎是随机的）。
C++客户端可以完整接收相同的消息。当发送ASCII文本时也没有问题。
我错过了什么？
- Python版本: 3.10
- Stomp版本: 7.0.0
- ActiveMQ版本: 5.16.3
发布者：
import randomimport stringimport timeimport sysimport stompimport oshosts = [('localhost', 61613)]conn = stomp.Connection(host_and_ports=hosts)conn.connect('admin', 'admin', wait=True)while 1:b = bytes(os.urandom(100))#b = ''.join(random.choices(string.ascii_lowercase, k=1500))print(len(b))conn.send(content_lengh=len(b), body=b, destination='/queue/test')time.sleep(2)conn.disconnect()
订阅者：
import timeimport sysimport stompclass MyListener(stomp.ConnectionListener):def on_error(self, frame):print('received an error "%s"' % frame.body)def on_message(self, frame):print(type(frame.body))print('received message len = "%s"' % len(frame.body))conn = stomp.Connection()conn.set_listener('', MyListener())conn.connect('admin', 'password', wait=True)conn.subscribe(destination='/queue/test', id=1, ack='auto')print("Waiting for messages...")while 1:time.sleep(10)conn.disconnect()
英文:
I am trying to exchange binary messages between two Python STOMP clients.
Message sending and receiving have no issues. However, there are always a few bytes (seems random) missing on the receiver.
The same messages are received in whole by C++ clients. No issue either when ASCII text are sent.
What am I missing?
- Python: 3.10
- Stomp: 7.0.0
- ActiveMQ: 5.16.3
Publisher:
import randomimport stringimport timeimport sysimport stompimport oshosts = [('localhost', 61613)]conn = stomp.Connection(host_and_ports=hosts)conn.connect('admin', 'admin', wait=True)while 1:b = bytes(os.urandom(100))#b = ''.join(random.choices(string.ascii_lowercase, k=1500))print(len(b))conn.send(content_lengh=len(b), body=b, destination='/queue/test')time.sleep(2)conn.disconnect()
Subscriber:
import timeimport sysimport stompclass MyListener(stomp.ConnectionListener):def on_error(self, frame):print('received an error "%s"' % frame.body)def on_message(self, frame):print(type(frame.body))print('received message len = "%s"' % len(frame.body))conn = stomp.Connection()conn.set_listener('', MyListener())conn.connect('admin', 'password', wait=True)conn.subscribe(destination='/queue/test', id=1, ack='auto')print("Waiting for messages...")while 1:time.sleep(10)conn.disconnect()
答案1
得分: 0
我通过跟踪 STOMP 协议自己找到了解决方法。订阅者需要禁用自动解码，如下所示。否则，帧的内容将被解码为 UTF-8。
conn = stomp.Connection(auto_decode=False)
英文:
I figured it out myself by tracing STOMP. The subscriber needs to disable auto decode as shown below. Otherwise, the frame body will be decoded as UTF-8.
conn = stomp.Connection(auto_decode=False)
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论