1、简介
RabbitMQ是消息代理&＃xff1a;它接受和转发消息。你可以把它当作一个邮局&＃xff1a;当你把你要邮寄的邮件放在信箱里时&＃xff0c;你可以肯定Postman先生最终会把邮件送到你的收件人那里。在这个比喻中&＃xff0c;RabbitMQ是邮局&＃xff0c;邮局邮差。RabbitMQ和邮局之间的主要区别是&＃xff0c;它不处理纸张&＃xff0c;而是接受、存储和转发二进制数据‒消息。
整体的设计如下图&＃xff1a;
java环境下&＃xff0c;使用rabbitmq需要用到jar包&＃xff1a;amqp-client.jar
2、发送消息
想要将消息发送到队列中&＃xff0c;我们需要进行下面几步&＃xff1a;
&＃xff08;1&＃xff09;建立服务链接
1 ConnectionFactory factory &＃61; new ConnectionFactory();
2 factory.setHost("localhost"); // 设置ip地址
3 factory.setPort(5672); // rabbit的端口号&＃xff0c;默认为5672&＃xff0c;可以不写
4 factory.setPassword("rabbit"); // 发送消息用户的登录密码
5 factory.setUsername("rabbit"); // 发送消息用户的登录用户名
6 Connection connection &＃61; factory.newConnection(); // 新建链接
7 Channel channel &＃61; connection.createChannel(); // 创建channel
&＃xff08;2&＃xff09;声明消息队列
1 channel.queueDeclare("QUEUE_NAME", false, false, false, null);
&＃xff08;3&＃xff09;调用方法发送消息
1 String message &＃61; "Hello World!"; // 待发送的消息
2 channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
&＃xff08;4&＃xff09;发送消息过后&＃xff0c;需要关闭链接
1 channel.close();
2 connection.close();
3、接收消息
接下来&＃xff0c;当生产者将消息发送到队列之后&＃xff0c;我们消费者一方就可以从队列中接收到消息了&＃xff1a;
&＃xff08;1&＃xff09;建立服务器链接&＃xff0c;和生产者一方一样
1 ConnectionFactory factory &＃61; new ConnectionFactory();
2 factory.setHost("localhost"); // 设置ip地址
3 factory.setPort(5672); // rabbit的端口号&＃xff0c;默认为5672&＃xff0c;可以不写
4 factory.setPassword("rabbit"); // 发送消息用户的登录密码
5 factory.setUsername("rabbit"); // 发送消息用户的登录用户名
6 Connection connection &＃61; factory.newConnection(); // 新建链接
7 Channel channel &＃61; connection.createChannel(); // 创建channel
&＃xff08;2&＃xff09;声明消息队列
1 channel.queueDeclare("QUEUE_NAME", false, false, false, null);
&＃xff08;3&＃xff09;声明回调方法&＃xff0c;接收服务器从队列中发过来的消息
1 Consumer consumer &＃61; new DefaultConsumer(channel) {
2 &＃64;Override
3 public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
6 String message &＃61; new String(body, "UTF-8");
7 System.out.println(" [x] Received &＃39;" &＃43; message &＃43; "&＃39;");
8 }
9 };
10 channel.basicConsume(QUEUE_NAME, true, consumer);
4、运行查看结果
分别运行生产者方和消费者方的代码过后&＃xff0c;通过生产者方发送消息过后&＃xff0c;就可以在消费者方接收到发送过来的数据了。
京公网安备 11010802041100号