RabbitMQ 一二事 - 简单队列使用
消息队列目前流行的有三种
1. RabbitMQ
2. ActiveMQ
3. Kafka
这三种都非常强大,RabbitMQ目前用的比较多,也比较流行,阿里也在用
ActiveMQ是阿帕奇出品,但是性能上和RMQ相比相对差一些
卡夫卡呢,使用场景不同,不多介绍,主要是用于日志收集方面,结合hadoop非常灵活
RabbitMQ官网:http://www.rabbitmq.com/
安装不多说了,可以下载Windows版本,或者linux版本 下载页面:http://www.rabbitmq.com/download.html
我在linux虚拟机上安装的,安装步骤简单,rpm直接安装就行,步骤就略了
成功后可以看到如下页面:
简答队列图
pom方面需要引入如下jar包
1 <dependencies> 2 3 <dependency> 4 <groupId>com.rabbitmq</groupId> 5 <artifactId>amqp-client</artifactId> 6 <version>3.4.1</version> 7 </dependency> 8 9 <dependency> 10 <groupId>org.slf4j</groupId> 11 <artifactId>slf4j-log4j12</artifactId> 12 <version>1.7.7</version> 13 </dependency> 14 15 <dependency> 16 <groupId>org.apache.commons</groupId> 17 <artifactId>commons-lang3</artifactId> 18 <version>3.3.2</version> 19 </dependency> 20 21 <dependency> 22 <groupId>org.springframework.amqp</groupId> 23 <artifactId>spring-rabbit</artifactId> 24 <version>1.5.6.RELEASE</version> 25 </dependency> 26 27 </dependencies>
定义一个类似连接池的类
public class ConnectionUtil {public static Connection getConnection() throws Exception {// 定义连接工厂ConnectionFactory factory = new ConnectionFactory();// 设置服务地址factory.setHost("192.168.1.205");// 端口factory.setPort(5672);// 设置账号信息,用户名、密码、vhostfactory.setVirtualHost("lee-shop");factory.setUsername("lee");factory.setPassword("lee");// 通过工程获取连接Connection connection = factory.newConnection();return connection;}}
创建生产者
1 public class Send { 2 3 private final static String QUEUE_NAME = "test_queue"; 4 5 public static void main(String[] argv) throws Exception { 6 // 获取到连接以及mq通道 7 Connection connection = ConnectionUtil.getConnection(); 8 // 从连接中创建通道 9 Channel channel = connection.createChannel(); 10 11 // 声明(创建)队列 12 channel.queueDeclare(QUEUE_NAME, false, false, false, null); 13 14 // 消息内容 15 String message = "Hello World!"; 16 channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); 17 System.out.println(" [x] Sent '" + message + "'"); 18 19 // 关闭通道和连接 20 channel.close(); 21 connection.close(); 22 } 23 }
创建消费者
1 public class Recv { 2 3 private final static String QUEUE_NAME = "test_queue"; 4 5 public static void main(String[] argv) throws Exception { 6 7 // 获取到连接以及mq通道 8 Connection connection = ConnectionUtil.getConnection(); 9 Channel channel = connection.createChannel(); 10 11 // 声明队列 12 channel.queueDeclare(QUEUE_NAME, false, false, false, null); 13 14 // 定义队列的消费者 15 QueueingConsumer consumer = new QueueingConsumer(channel); 16 // 监听队列 17 channel.basicConsume(QUEUE_NAME, true, consumer); 18 19 // 获取消息 20 while (true) { 21 QueueingConsumer.Delivery delivery = consumer.nextDelivery(); 22 String message = new String(delivery.getBody()); 23 System.out.println(" [x] Received '" + message + "'"); 24 } 25 } 26 }
debug的时候可以进入rmq的管理页面查看对于的连接数,频道,以及消息队列:
消费者接受到的消息:
对应的官网英文文档如下:
http://www.rabbitmq.com/getstarted.html
RabbitMQ 一二事 - 简单队列使用相关推荐
- RabbitMQ快速入门--简单队列模型
入门案例 简单队列模式的模型图: 官方的HelloWorld是基于最基础的消息队列模型来实现的,只包括三个角色: publisher:消息发布者,将消息发送到队列queue queue:消息队列,负责 ...
- RabbitMQ 一二事(2) - 工作队列使用
上篇文章讲了简单队列的使用,这其实就是RMQ给的demo,实际并没有什么用 本篇讲讲工作模式队列,也称之为任务队列 一个生产者发布了多条消息,消费者A可以接受消息,接受消息后该消息就消除,消费者B可以 ...
- RabbitMQ 一二事(4) - 路由模式介绍
路由模式其实和订阅模式差不多,只不过交换机的类型不同而已 路由模式可以用下图来表示,比订阅模式多了一个key,举个栗子就是根据不同的人群来订阅公众号,来收取消息 根据不同的key来获取不同的消息 最简 ...
- rabbitmq几种工作模式_RabbitMQ六种队列模式-简单队列模式
在官网的教程中,描述了如上六类工作队列模式: 简单队列模式:最简单的工作队列,其中一个消息生产者,一个消息消费者,一个队列.也称为点对点模式. 工作模式:一个消息生产者,一个交换器,一个消息队列,多个 ...
- RabbitMQ简单队列模式
简单队列模式 红色:队列 P:消息的生产者 C:消息的消费者 生产者,将消息发送到队列 消费者,从队列中获取消息 配置依赖 导入RabbitMQ客户端依赖 <dependency>< ...
- 获取rabbitmq连接对象_RabbitMQ——简单队列
RabbitMQ 简述# RabbitMQ是一个消息代理:它接受并转发消息. 您可以将其视为邮局:当您将要把寄发的邮件投递到邮箱中时,您可以确信Postman 先生最终会将邮件发送给收件人. 在这个比 ...
- RabbitMQ六种队列模式-简单队列模式
前言 RabbitMQ六种队列模式-简单队列 [本文] RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列 ...
- 【转】RabbitMQ六种队列模式-1.简单队列模式
前言 RabbitMQ六种队列模式-简单队列 [本文] RabbitMQ六种队列模式-工作队列 RabbitMQ六种队列模式-发布订阅 RabbitMQ六种队列模式-路由模式 RabbitMQ六种队列 ...
- RabbitMQ的5种队列_简单队列_入门试炼_第4篇
Statement 文章目录 一.队列总览 1.1. 图示 1.2. 说明 二.简单队列 2.1. 图示 2.2. 导入RabbitMQ的客户端依赖 2.3. 获取MQ的连接 2.4. 生产者发送消息 ...
最新文章
- 某程序员为让公司裁掉自己,消极怠工!故意旷工!但公司坚持不裁他,领导:给你发工资,就是不裁你!...
- Attack on Alpha-Zet
- Oracle真实世界数据链——将现实世界和区块链世界相互打通——让主流币爆涨十倍的项目
- android:configChanges=keyboard|keyboardHidden|orientation|screenSize
- ASP.NET MVC涉及到的5个同步与异步,你是否傻傻分不清楚?[下篇]
- 【AI基础】OpenCV,PIL,Skimage你pick谁
- pearsonr() python_Python 来算算一线城市的二手房价格指数相关性
- 2022.4.9 mac os M1 芯片 12.3.1 Monterey 安装cocoapods
- 银行卡注销快捷支付协议
- 7-5-无向图生成树-图-第7章-《数据结构》课本源码-严蔚敏吴伟民版
- 日常学习随笔-数组、单链表、双链表三种形式实现队列结构的基本操作(源码注释)...
- Markdown list状态下插入代码
- Salesforce入门教程(中文)-019 VF创建输入表单
- linux命令 速记表图片,linux命令速记
- win7计算机名怎么是感叹号,Win7连接wifi信号后出现感叹号三种原因和解决方法
- python 列表嵌套字典 添加修改删除_python3--字典,字典的嵌套,概念:分别赋值
- 信道特征(码元、比特、波特率等概念)
- Expanding Cards
- 数据仓库之主题模型之IBM与TD金融模型
- C++算法与设计学习记录