分布式消息服务RABBITMQ版-使用客户端连接RabbitMQ（开启SSL）:示例代码（Java）

时间：2024-07-30 10:35:31

分布式消息服务RABBITMQ版连接实例

示例代码（Java）

连接实例并生产消息示例代码：

VHOST_NAME：消息要发送的Queue所在的Vhost名称。
QUEUE_NAME：消息要发送的Queue名称。
Hello World!：要发送的消息，根据实际需要修改。

ConnectionFactory factory = new ConnectionFactory();
 factory.setHost(host);
 factory.setPort(port);
 factory.setVirtualHost("VHOST_NAME");

 factory.setUsername(user);
 factory.setPassword(password);
 factory.useSslProtocol();
 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("UTF-8"));
 System.out.println(" [x] Sent '" + message + "'");

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

连接实例并消费消息示例代码：

VHOST_NAME：要消费消息的Queue所在的Vhost名称。
QUEUE_NAME：要消费消息的Queue名称。

ConnectionFactory factory = new ConnectionFactory();
 factory.setHost(host);
 factory.setPort(port);
 factory.setVirtualHost("VHOST_NAME");
 factory.setUsername(user);
 factory.setPassword(password);
 factory.useSslProtocol();
 Connection connection = factory.newConnection();
 Channel channel = connection.createChannel();

 channel.queueDeclare(QUEUE_NAME, false, false, false, null);
 System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

 Consumer consumer = new DefaultConsumer(channel)
 {
     @Override
     public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties,
             byte[] body)
             throws IOException
     {
         String message = new String(body, "UTF-8");
         System.out.println(" [x] Received '" + message + "'");
     }
 };
 channel.basicConsume(QUEUE_NAME, true, consumer);

上一篇：分布式消息服务RABBITMQ版-使用客户端连接RabbitMQ（开启SSL）:前提条件

下一篇：分布式消息服务RABBITMQ版-使用客户端连接RabbitMQ（开启SSL）:前提条件