phpstompactivemqPython 应用 STOMP 向 ActiveMQ 轮回发送新闻

To send messages to an ActiveMQ broker using the STOMP protocol in a loop with Python, you can use the stomp.py library. First, you’ll need to ensure the library is installed. You can install it using pip if you haven’t already:

pip install stomp.py

Here’s a simple example of how to send messages in a loop:

import stompimport timeclass MyListener(stomp.ConnectionListener): def on_error(self, headers, message): print('received an error: "%s"' % message) def on_disconnected(self): print('disconnected')def send_messages(): conn = stomp.Connection([('localhost', 61613)]) conn.set_listener('', MyListener()) conn.connect('admin', 'password', wait=True) for i in range(10): # Send 10 messages message = f'Message number {i + 1}' conn.send(destination='/queue/test', body=message) print(f'Sent: {message}') time.sleep(1) conn.disconnect()if __name__ == '__main__': send_messages()Key Points:Connection Setup: Replace 'localhost' and 61613 with your ActiveMQ server’s host and port.Authentication: Replace 'admin' and 'password' with your ActiveMQ username and password.Queue Name: Adjust the destination='/queue/test' to the queue you want to send messages to.Loop: Adjust the range and time.sleep() for the number of messages and delay between sends as needed.

This script establishes a connection to the ActiveMQ broker, sends a series of messages to a specified queue, and then disconnects.

phpstompactivemqPython 应用 STOMP 向 ActiveMQ 轮回发送新闻 SQL

GPT

GPT 的回答基本上办理了问题。

碰着的问题是，在向 ActiveMQ 发送的时候，我们有一个 SendMQ 的方法。

在这个方法将会打开连接发送后关闭连接。

我们的问题在：现在须要向 MQ 发送 1 万多条，这个循环放那里。

开始我们把这个循环放在了内层，这里就涌现了一个问题，Python 的循环会异步调用 Close 这方法，然后导致全体程序的挂起。

通过上面 GPT 的回答，我知道该当在全体循环的最外层打开连接，循环内不能再次打开连接和关闭连接。

等把这 1 万多条发送成功后再关闭连接。

同样的问题，我们也利用了 claude_3_haiku_bot 这个模型来问了这个问题，请参考后面的。

觉得 GPT4 的模型对这个问题回答得更好一些。

Let’s see what topics on “python stomp sending in loop” I can find on the iSharkFly forum:

Hmm, I couldn’t find any specific topics about “python stomp sending in loop” on this forum. Let me try a more general search:

The search results provide some relevant information about using the Python stomp library to send messages, including:

There was an issue where the messages were being sent as binary data instead of text, due to the auto_content_length setting. Setting this to False resolved the issue.There is sample code showing how to connect to an ActiveMQ message queue using stomp, send a message, and disconnect.

Based on this, it seems the main issue you are encountering is getting the messages to display correctly on the message server. The key things to try are:

Make sure you are setting auto_content_length=False when creating the stomp connection.Ensure the message content you are sending is properly formatted as text, not binary data.Check that the message server is configured to display text messages correctly.

If you are still having issues, you could try searching for more specific information about the “python stomp sending in loop” use case, or providing more details about the exact problem you are facing.

Google AI 的回答貌似也还行。

关于写代码，真的可以问问 AI。