java版RabbitMQ的hello world实现

缺乏、安全感 2022-06-05 11:52 100阅读 0赞

windows安装RabbitMq：  
[http://blog.csdn.net/leisure\_life/article/details/78642799][http_blog.csdn.net_leisure_life_article_details_78642799]  
  
官网教程：[http://www.rabbitmq.com/tutorials/tutorial-one-java.html][http_www.rabbitmq.com_tutorials_tutorial-one-java.html]

### 请确保正确安装了上述环境并使之处于运行状态    ###

#####    一下教程是根据官网教程操作的步骤      建一个Java项目，根据官网提示下载相应jar包：      jar包地址：      [amqp-client-4.0.2.jar][]      [slf4j-api-1.7.21.jar][]      [slf4j-simple-1.7.22.jar][]      ![这里写图片描述][SouthEast] #####

# 代码 #

### send.java ###

package com.adtec.rabbitmq;
    
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.ConnectionFactory;
    
    public class Send {
    
      private final static String QUEUE_NAME = "hello";
    
      public static void main(String[] argv) throws Exception {
        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("UTF-8"));
        System.out.println(" [x] Sent '" + message + "'");
    
        channel.close();
        connection.close();
      }
    }

### Recv.java ###

package com.adtec.rabbitmq;
    
    import com.rabbitmq.client.*;
    
    import java.io.IOException;
    
    public class Recv { 
    
      private final static String QUEUE_NAME = "hello";
    
      public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        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);
      }
    }

### 运行send.java结果 ###

[x] Sent 'Hello World!'

### 运行Recv.java结果 ###

[*] Waiting for messages. To exit press CTRL+C
     [x] Received 'Hello World!'

[http_blog.csdn.net_leisure_life_article_details_78642799]: http://blog.csdn.net/leisure_life/article/details/78642799
[http_www.rabbitmq.com_tutorials_tutorial-one-java.html]: http://www.rabbitmq.com/tutorials/tutorial-one-java.html
[amqp-client-4.0.2.jar]: http://central.maven.org/maven2/com/rabbitmq/amqp-client/4.0.2/amqp-client-4.0.2.jar
[slf4j-api-1.7.21.jar]: http://central.maven.org/maven2/org/slf4j/slf4j-api/1.7.21/slf4j-api-1.7.21.jar
[slf4j-simple-1.7.22.jar]: http://central.maven.org/maven2/org/slf4j/slf4j-simple/1.7.22/slf4j-simple-1.7.22.jar
[SouthEast]: https://img-blog.csdn.net/20171127110016401?watermark/2/text/aHR0cDovL2Jsb2cuY3Nkbi5uZXQvbGVpc3VyZV9saWZl/font/5a6L5L2T/fontsize/400/fill/I0JBQkFCMA==/dissolve/70/gravity/SouthEast