增加maven配置文件

    		
     
      com.rabbitmq
     		
     
      amqp-client
     		
     
      3.6.5
     	
    复制代码

生产者

package com.jeff.boot.controller.rabbitmq; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; import com.rabbitmq.client.ConnectionFactory; import java.io.IOException; import java.util.concurrent.TimeoutException;

public class Producer { public final static String QUEUE_NAME="rabbitMQtest";

public static void main(String[] args) throws IOException, TimeoutException {    //创建连接工厂    ConnectionFactory factory = new ConnectionFactory();    //设置RabbitMQ相关信息    factory.setHost("");    factory.setUsername("");    factory.setPassword("");    factory.setPort(5672);    //创建一个新的连接    Connection connection = factory.newConnection();    //创建一个通道    Channel channel = connection.createChannel();    //  声明一个队列    channel.queueDeclare(QUEUE_NAME, false, false, false, null);    String message = "Hello RabbitMQ";    int i = 0;    //发送消息到队列中    while (i < 100 ) {        channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));        System.out.println("Producer Send +'" + message + "'");        //关闭通道和连接        i++;    }    channel.close();    connection.close();}复制代码

}

消费者

package com.jeff.boot.controller.rabbitmq;

import com.rabbitmq.client.*; import java.io.IOException; import java.util.concurrent.TimeoutException;

public class Customer { private final static String QUEUE_NAME = "rabbitMQtest";

public static void main(String[] args) throws IOException, TimeoutException {    // 创建连接工厂    ConnectionFactory factory = new ConnectionFactory();    //设置RabbitMQ地址    factory.setHost("192.168.226.53");    //创建一个新的连接    Connection connection = factory.newConnection();    //创建一个通道    Channel channel = connection.createChannel();    //声明要关注的队列    channel.queueDeclare(QUEUE_NAME, false, false, false, null);    System.out.println("Customer Waiting Received messages");    //DefaultConsumer类实现了Consumer接口，通过传入一个频道，    // 告诉服务器我们需要那个频道的消息，如果频道中有消息，就会执行回调函数handleDelivery    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("Customer Received '" + message + "'");        }    };    //自动回复队列应答 -- RabbitMQ中的消息确认机制    channel.basicConsume(QUEUE_NAME, true, consumer);}复制代码

}