1,python調用MQ發送消息(生產者),話不多說,直接上干貨

　　import pika? ? ?

　　如下圖

2.java調用MQ發送消息(生產者)

具體代碼如下:

python 的代碼如下

connection = pika.BlockingConnection(pika.ConnectionParameters('IP',端口,'/'))
channel =connection.channel()
msg_props = pika.BasicProperties()
msg_props.content_type="text/plain"
channel.basic_publish(exchange='EXCHANGE_ORDER_NEW',routing_key='QUEUE_WECHAT_ORDER',body='數據信息',properties=msg_props)
connection.close()

java調用MQ的代碼如下:

　　ConnectionFactory factory=new ConnectionFactory();
　　factory.setHost("IP地址");
　　factory.setPort(1111);
　　Connection connection=factory.newConnection();
　　Channel channel = connection.createChannel();
　　channel.queueDeclare("設置隊列隊列名_NEW", false, false, false, null);
　　String message="要發送的消息";
　　BasicProperties properties = new BasicProperties("text", null, null, null, null, null, null, null, null, null, null, null, null, null);
　　channel.basicPublish("設置隊列隊列名_NEW", "隊列名", properties, message.getBytes("UTF-8"));
　　channel.close();
　　connection.close();

轉載于:https://www.cnblogs.com/xiaoqiang5120/p/8318173.html

總結

以上是生活随笔為你收集整理的java及python调用RabbitMQ的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。