Используем RabbitMQ под Java
Для использования RabbitMQ в Java нужно использовать следующие библиотеки:
|
1 2 3 |
amqp-client-5.4.2.jar - собственно RabbitMQ клиент slf4j-api-1.7.25.jar - библиотека для логгирования slf4j-simple-1.7.25.jar- библиотека для логгирования |
Библиотека SLF4J требуется для корректной работы amqp-client. Скачать можно тут
Пример кода для отправки данных (Java)
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 |
import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; public class RabbitMQ { public void send(String message) throws Exception { ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); Connection connection = factory.newConnection(); Channel channel = connection.createChannel(); channel.queueDeclare("hello", false, false, false, null); channel.basicPublish("", "hello", null, message.getBytes()); System.out.println(" [x] Sent '" + message + "'"); channel.close(); connection.close(); } } |
Пример кода для приема (Python)
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 |
import pika connection = pika.BlockingConnection(pika.ConnectionParameters( host='localhost', port=5672, virtual_host='/')) channel = connection.channel() channel.queue_declare(queue='hello') print(' [*] Waiting for messages. To exit press CTRL+C') def callback(ch, method, properties, body): print(" [x] Received %r" % (body,)) channel.basic_consume(callback, queue='hello', no_ack=True) channel.start_consuming() |