RabbitMQ在我的队列中写入了错误的字符

可能是因为不同的字符编码导致的问题，你可以使用Python的chardet库来检测消息的编码，并使用相应的编码方式发送和接收消息。代码示例如下：

发送消息：

import pika import chardet

connection = pika.BlockingConnection( pika.ConnectionParameters(host='localhost')) channel = connection.channel()

message = "你好，世界！" message_bytes = message.encode("utf-8") message_encoding = chardet.detect(message_bytes)['encoding']

channel.basic_publish(exchange='', routing_key='hello', body=message_bytes, properties=pika.BasicProperties(content_type=f"text/plain;charset={message_encoding}")) print(" [x] Sent 'Hello World!'") connection.close()

接收消息：

import pika import chardet

connection = pika.BlockingConnection( pika.ConnectionParameters(host='localhost')) channel = connection.channel()

method_frame, header_frame, body = channel.basic_get(queue='hello') if method_frame: message_encoding = header_frame.content_encoding message = body.decode(message_encoding)
print(f"Received message: {message}") channel.basic_ack(method_frame.delivery_tag) else: print("No message available right now") connection.close()

注意：在这个例子中，我们使用UTF-8作为消息的编码方式。你需要根据你的具体需求使用适合的编码方式来发送和接收消息。