系列文章

RabbitMq系列(一)：服务器搭建

RabbitMq系列(二)：最简单的例子

目录

前言

添加依赖

创建生产者

创建消费者

测试

其他

前言

前面已经把RabbitMq服务器搭起来，并且添加了一个基本用户，这里基于服务器构建最基本的RabbitMq程序(一个消费者和一个生产者)。

添加依赖

这里使用最新(当前5.9.0)的java客户端依赖：

 <dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.9.0</version></dependency>

创建生产者

public class MQProducer {public static void main(String[] args) {try {produceMsg("rabbitmq.first","第一条消息");} catch (IOException e) {e.printStackTrace();} catch (TimeoutException e) {e.printStackTrace();}}public static void produceMsg(String queue,String msg) throws IOException, TimeoutException {//创建连接工厂ConnectionFactory connectionFactory = new ConnectionFactory();//设置连接地址connectionFactory.setHost("192.168.239.128");//设置连接端口(默认配置)connectionFactory.setPort(5672);//设置连接用户(默认配置)connectionFactory.setUsername("guest");//设置连接密码(默认配置)connectionFactory.setPassword("guest");//设置连接虚拟机(默认配置)connectionFactory.setVirtualHost("/");//创建连接Connection connection = connectionFactory.newConnection();//创建通道Channel channel = connection.createChannel();//声明队列(如果队列不存在，会创建)channel.queueDeclare(queue,true,false,false,null);//创建生产者channel.basicPublish("",queue,null,msg.getBytes());//关闭连接channel.close();connection.close();}
}

 部分  lambda 表达式需要 8 以上的语法支持，请注意开发工具环境

另外，释放资源最好在 finally 方法体内

创建消费者

/*** 消费者*/
public class MQConsumer {public static void main(String[] args) {try {consumeMsg("rabbitmq.first");} catch (IOException e) {e.printStackTrace();} catch (TimeoutException e) {e.printStackTrace();}}/*** 消费消息构建* @param queue* @throws IOException* @throws TimeoutException*/public static void consumeMsg(String queue) throws IOException, TimeoutException {//创建连接工厂ConnectionFactory connectionFactory = new ConnectionFactory();//设置连接地址connectionFactory.setHost("192.168.239.128");//设置端口(默认配置)connectionFactory.setPort(5672);//设置用户(默认配置)connectionFactory.setUsername("guest");//设置密码(默认配置)connectionFactory.setPassword("guest");//设置连接虚拟主机(默认配置)connectionFactory.setVirtualHost("/");//创建连接Connection connection = connectionFactory.newConnection();//创建通道(大部)Channel channel = connection.createChannel();//创建回调DeliverCallback deliverCallback = (consumerTag, message) -> {String msg = new String(message.getBody(), "utf-8");System.out.println(msg);};//声明队列(如果队列不存在，会主动创建)channel.queueDeclare(queue,true,false,false,null);//创建生产者channel.basicConsume(queue,true,deliverCallback,consumerTag -> {});//关闭channel,connection/*channel.close();connection.close();*/}
}

 部分  lambda 表达式需要 8 以上的语法支持，请注意开发工具环境

另外，这里没释放连接资源是因为要一直监听消息等待。

测试

先启动 MQProducer 再启动  MQConsumer，查看控制台：

消息接收成功！

其他

ConnectFacytory大部分参数都有默认值，这里除了 host 需要配置，如果没有自定义虚拟机、用户名、密码等，都是不用配置的，相当于下面的可以省略(消费者与生产者一样)：

//设置连接端口(默认配置)
connectionFactory.setPort(5672);
//设置连接用户(默认配置)
connectionFactory.setUsername("guest");
//设置连接密码(默认配置)
connectionFactory.setPassword("guest");
//设置连接虚拟机(默认配置)
connectionFactory.setVirtualHost("/");