RabbitMQ学习第一记：用java连接RabbitMQ
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了RabbitMQ学习第一记：用java连接RabbitMQ，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含2738字，纯文字阅读大概需要4分钟。
内容图文
1、什么是RabbitMQ
MQ（Message Queue）：消息队列，是服务端设计的一个可以存储大量消息的队列，并提供客户端操作队列的方法：生产队列（向队列中添加数据）、消费队列（从队列中取数据）。RabbitMQ就是基于消息队列的一个典型应用。RabbitMQ除了普通的生产消费功能，还有一些高级功能：公平分发 ，轮询分发，路 由模式，通配符模式，发布订阅，队列持久化。
2、java实现RabbitMQ的连接
2.1、RabbitMQ客户端jar包
<
dependency
>
<
groupId
>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>4.0.2</version></dependency>
2.2、java连接RabbitMQ工具类
public
class
ConnectionUtil
{
private
static Logger logger = Logger.getLogger(ConnectionUtil.class);
publicstatic Connection getConnection()
{
try
{
Connection connection = null;
//定义一个连接工厂
ConnectionFactory factory = new ConnectionFactory();
//设置服务端地址（域名地址/ip）
factory.setHost("127.0.0.1");
//设置服务器端口号
factory.setPort(5672);
//设置虚拟主机(相当于数据库中的库)
factory.setVirtualHost("/");
//设置用户名
factory.setUsername("admin");
//设置密码
factory.setPassword("888888");
connection = factory.newConnection();
return connection;
}
catch (Exception e)
{
returnnull;
}
}
}
2.3、简单的生产者-消费者模式
下图取自于官方网站（RabbitMQ）的生产消费模式的工作图
P：消息的生产者
C：消息的消费者
红色：队列
生产者将消息发送到队列，消费者从队列中获取消息。
2.4、生产者（Send）
public
class
Send
{
//
队列名称
private
static
final String QUEUE_NAME = "test_simple_queue";
publicstaticvoid main(String[] args)
{
try
{
//获取连接
Connection connection = ConnectionUtil.getConnection();
//从连接中获取一个通道
Channel channel = connection.createChannel();
//声明队列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
String message = "This is simple queue";
//发送消息
channel.basicPublish("", QUEUE_NAME, null, message.getBytes("utf-8"));
System.out.println("[send]：" + message);
channel.close();
connection.close();
}
catch (IOException | TimeoutException e)
{
e.printStackTrace();
}
}
}
运行结果：
[send]：This is simple queue
2.5、消费者（Receive）
public
class
Receive
{
//
队列名称
private
static
final String QUEUE_NAME = "test_simple_queue";
publicstaticvoid main(String[] args)
{
try
{
//获取连接
Connection connection = ConnectionUtil.getConnection();
//从连接中获取一个通道
Channel channel = connection.createChannel();
//声明队列
channel.queueDeclare(QUEUE_NAME, false, false, false, null);
//定义消费者
DefaultConsumer consumer = new DefaultConsumer(channel)
{
//当消息到达时执行回调方法 @Override
publicvoid handleDelivery(String consumerTag, Envelope envelope, BasicProperties properties,
byte[] body) throws IOException
{
String message = new String(body, "utf-8");
System.out.println("[Receive]：" + message);
}
};
//监听队列
channel.basicConsume(QUEUE_NAME, true, consumer);
}
catch (IOException | ShutdownSignalException | ConsumerCancelledException e)
{
e.printStackTrace();
}
}
}
运行结果：
[Receive]：This is simple queue
总结：简单的生产者-消费者模式实现了生产者向队列里生产数据，消费者启动后可以一直监听队列，不断的从队列里取出数据。
注意：本文仅代表个人理解和看法哟！和本人所在公司和团体无任何关系！
原文：https://www.cnblogs.com/wy697495/p/9611310.html
内容总结
以上是互联网集市为您收集整理的RabbitMQ学习第一记：用java连接RabbitMQ全部内容，希望文章能够帮你解决RabbitMQ学习第一记：用java连接RabbitMQ所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。