环境准备

安装RabbitMq: 个人是先在Win10便携机上安装VMWare Workstation, 再安装Cent OS 操作系统，在此基础上安装RabbitMQ。

安装过程可以参考这篇博客： https://blog.csdn.net/hsxy123123/article/details/104006744

需要注意RabbitMQ官网提供的erlang与RabbitMQ的配套版本，按版本安装。

消息生产者Demo代码

    private final static String QUEUE_NAME = "elon_queue";/*** 生产消息发送到队列** @param messageBody 消息体* @author elon*/public void produceMessage(String messageBody) {ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.*.*.*");factory.setPort(5672);factory.setUsername("***");factory.setPassword("*******");try {Connection connection = factory.newConnection();Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false, false, false, null);channel.basicPublish("", QUEUE_NAME, null, messageBody.getBytes());LOGGER.info("Sent {}", messageBody);} catch (Exception e) {LOGGER.info("Produce message fail.", e);}}ren

发送消息使用默认交换器 “” ，指定队列名称elon_queue。

消息消费者Demo代码

    private final static String QUEUE_NAME = "elon_queue";/*** 消费消息*/public void consumeMessage() {ConnectionFactory factory = new ConnectionFactory();factory.setHost("192.168.43.134");factory.setPort(5672);factory.setUsername("yzy");factory.setPassword("yzy614114");try {Connection connection = factory.newConnection();Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false, false, false, null);DeliverCallback deliverCallback = (consumerTag, delivery) -> {String message = new String(delivery.getBody(), StandardCharsets.UTF_8);LOGGER.info("Receive message from queue:{}", message);};channel.basicConsume(QUEUE_NAME, true, deliverCallback, tag->{});} catch (Exception e) {LOGGER.error("Consume message exception.", e);}}

消费者增加 channel.queueDeclare(QUEUE_NAME, false, false, false, null) 这行代码是考虑消费者进程可能先于生产者启动的情况。