RabbitMQ入门（二）-helloworld

首先引入pom依赖：

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

启动项目之前把RabbitMQ启动

首先是OneProducer生产者：

package com.baidu.RabbitMQ.mq01;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;public class OneProducer {private static final String Queue_Name="rabbit:mq01:queue";public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("127.0.0.1");//TODO：点 ConnectionFactory 进去看看 会发现其中的userName跟password默认就是使用我下面两个设置，所以可以不需要设置//factory.setUsername("guest");//factory.setPassword("guest"); Connection connection = factory.newConnection();//TODO：channel贯穿通信的始终，连接了 "消息发送端-队列-消息接收端"Channel channel = connection.createChannel();//TODO：声明队列并将消息发送到队列中. 每个方法中的各个参数均可以 点进去 看看就一目了然. -> 此为简单的消息模型channel.queueDeclare(Queue_Name, true, false, false, null);String message = "我的第一条消息-Hello World!";channel.basicPublish("", Queue_Name, null, message.getBytes("UTF-8"));System.out.println("生产者发送消息成功---> ");channel.close();connection.close();} catch (Exception e) {e.printStackTrace();}}
}

接下来是是OneConsumer消费者：

package com.baidu.RabbitMQ.mq01;import java.io.IOException;import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Consumer;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;public class OneConsumer {private static final String Queue_Name="rabbit:mq01:queue";public static void main(String[] args) {try {ConnectionFactory factory = new ConnectionFactory();factory.setHost("127.0.0.1");Connection connection = factory.newConnection();Channel channel = connection.createChannel();channel.queueDeclare(Queue_Name, true, false, false, null);Consumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body)throws IOException {String message = new String(body, "UTF-8");System.out.println("消费端接受到消息---> "+message);}};//TODO：确认消费->这在SpringBoot整合将会进一步的细讲channel.basicConsume(Queue_Name, true, consumer);} catch (Exception e) {e.printStackTrace();}}
}

RabbitMQ入门（二）-helloworld相关推荐

RabbitMQ入门学习系列(二)，单生产者消费者
友情提示我对我的文章负责,发现好多网上的文章没有实践,都发出来的,让人走很多弯路,如果你在我的文章中遇到无法实现,或者无法走通的问题.可以直接在公众号<爱码农爱生活 >留言.必定会再次 ...
RabbitMQ入门到进阶
1.MQ简介 MQ 全称为 Message Queue,是在消息的传输过程中保存消息的容器.多用于分布式系统之间进行通信. 2.为什么要用 MQ 1.流量消峰没使用MQ 使用了MQ 2.应用解耦 ...
RabbitMQ入门到进阶(Spring整合RabbitMQSpringBoot整合RabbitMQ)
1.MQ简介 MQ 全称为 Message Queue,是在消息的传输过程中保存消息的容器.多用于分布式系统之间进行通信. 编辑切换为居中添加图片注释,不超过 140 字(可选) 2.为什么要 ...
RabbitMQ入门4：生产者、消费者演示；多个消费者平均压力、公平派遣；
说明: (1)内容说明: ● 这儿我们会创建一个项目,演示RabbitMQ最基础的内容: 通过,这个最简单的例子,先了解:如何使用RabbitMQ,如何连接RabbitMQ,如何发送消息,如何接收消息 ...
RabbitMQ（二）：RabbitMQ高级特性
RabbitMQ(二):RabbitMQ高级特性 RabbitMQ是目前非常热门的一款消息中间件,不管是互联网大厂还是中小企业都在大量使用.作为一名合格的开发者,有必要了解一下相关知识,RabbitM ...
轻松搞定RabbitMQ（二）——工作队列之消息分发机制
上一篇博文中简单介绍了一下RabbitMQ的基础知识,并写了一个经典语言入门程序--HelloWorld.本篇博文中我们将会创建一个工作队列用来在工作者(consumer)间分发耗时任务.同样是翻译的 ...
RabbitMQ入门：路由(Routing)
在上一篇博客<RabbitMQ入门:发布/订阅(Publish/Subscribe)>中,我们认识了fanout类型的exchange,它是一种通过广播方式发送消息的路由器,所有和exch ...
RabbitMQ入门-Topic模式
上篇<RabbitMQ入门-Routing直连模式>我们介绍了可以定向发送消息,并可以根据自定义规则派发消息.看起来,这个Routing模式已经算灵活的了,但是,这还不够,我们还有更加多样 ...
RabbitMQ入门：发布/订阅（Publish/Subscribe）
在前面的两篇博客中 RabbitMQ入门:Hello RabbitMQ 代码实例 RabbitMQ入门:工作队列(Work Queue) 遇到的实例都是一个消息只发送给一个消费者(工作者),他们的消息 ...
RabbitMQ入门到精通
RabbitMQ 1. 消息中间件概述 1.1. 为什么学习消息队列电子商务应用中,经常需要对庞大的海量数据进行监控,随着网络技术和软件开发技术的不断提高,在实战开发中MQ的使用与日俱增,特别是Ra ...

RabbitMQ入门（二）-helloworld

RabbitMQ入门（二）-helloworld相关推荐

最新文章

热门文章