JMS组件:activemq(慢)
AMQP组件(advance message queue protocol):rabbitmq和kafka
一.、消息队列解决了什么问题?
异步处理
应用解耦
流量削锋
日志处理
二、rabbitmq安装与配置
三、java操作rabbitmq
1. simple 简单队列
2. work queues 工作队列 公平分发 轮询分发
3. publish/subscribe 发布于订阅
4. routing 路由选择 通配符模式
5. topics 主题
6. 手动和自动确认消息
7. 队列的持久化和非持久化
8. rabbitmq的延迟队列
四、spring AMQP spring-rabbitmq
五、场景demo mq实现搜索引擎DIH增量
六、场景demo 未支付订单30分钟,取消
七、大数据应用 类似百度统计 cnzz架构 消息队列
一、简单队列
ConnectionUtils.java
1 public class ConnectionUtils { 2 public static Connection getConnection() throws IOException, TimeoutException { 3 ConnectionFactory factory = new ConnectionFactory(); 4 factory.setHost("127.0.0.1"); 5 factory.setPort(5672); 6 factory.setVirtualHost("/vhost_mmr"); 7 factory.setUsername("cxx"); 8 factory.setPassword("cxx"); 9 return factory.newConnection(); 10 } 11 }