Java/Python Kommunikation über RabbitMQ

Question

Ich möchte eine Messaging-Anwendung mit Java als Produzent und Python als Verbraucher der Nachricht über RabbitMQ entwickeln. Bitte schlagen Sie vor, wie ich das machen kann. Danke für Ihre Vorschläge und Kommentare.

Answer 1

Lassen Sie mich die documentation für Sie lesen.

reciever.py

import pika 

def callback(ch, method, properties, body): 
    print(body) 

connection = pika.BlockingConnection(pika.ConnectionParameters('localhost')) 
channel = connection.channel() 
channel.queue_declare(queue='some_queue') 

channel.basic_consume(callback, 
         queue='some_queue', 
         no_ack=True) 

channel.start_consuming() 

sender.java

import com.rabbitmq.client.ConnectionFactory; 
import com.rabbitmq.client.Connection; 
import com.rabbitmq.client.Channel; 

public class Send { 
    private final static String QUEUE_NAME = "some_queue"; 

    public static void main(String[] argv) throws java.io.IOException { 
     ConnectionFactory factory = new ConnectionFactory(); 
     factory.setHost("localhost"); 
     Connection connection = factory.newConnection(); 
     Channel channel = connection.createChannel(); 
     channel.queueDeclare(QUEUE_NAME, false, false, false, null); 

     String message = "Hello World!"; 
     channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); 

     channel.close(); 
     connection.close(); 
    } 
}