RabbitMQによるJava/Python通信

Question

私はRabbitMQを通じてメッセージのコンシューマとしてプロデューサとPythonとしてjavaを使用してメッセージングアプリケーションを開発したいと考えています。どうすればいいのか教えてください。あなたの提案とコメントをありがとう。

Answer 1

あなたのためにdocumentationを読ませてください。

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(); 
    } 
}