消息中间件

简介：
Message MiddleWare
消息中间件是在消息的传递过程中保存消息的容器。
消息中间件再将消息从它的源中继到它的目标时，充当中间人的作用。

消息包括：订单信息等，需要消费者处理的东西

特点：
1）异步处理模式  发送者发送消息而无需等待响应。消息发送者将消息发送到一条虚拟的通道上，消息接受者则订阅或监听该通道。
                 一条消息可能最终转发给一个或者多个消息接收者，这些消息接收者无需对消息发送者做出同步回应。整个过程是异步的
2）松耦合 发送者和接受者不必了解对方 只需要确认消息
					发送者和接受者不必同时在线

消息传递服务模型：

点对点模型PTP：点对点模型用于生产者消费者之间的点到点的通信  队列消息可放在内存中也可以是持久的。
					 特性：1）只有一个消费者
					 			 2）没有时间依赖
					 			 3）接受者确认消息和接收处理请求
				 			 
发布-订阅模型Pub-Sub：TOPIC 订阅者发布者模型支持向一个特定的消息主题生产消息
				特性：1）每个消息可以有多个订阅者
							2）订阅后才能接收到消息
							3）持久订阅和非持久订阅（持久订阅：订阅方重启后，发布方会重新发消息给订阅方，互联网公司常用。比如支付场景，要求强一致性的业务。
																		 非持久订阅：重启后，不会重新发消息，通知消息，一致性要求不高）
					    4）时间依赖 只有建立订阅关系才能接受消息
					    5）持久订阅：关系建立后，消息不会消失，不管订阅者是否在线
					    6）非持久订阅：订阅者为了接受消息，必须一直在线
        
消息中间件过程：

应用程序A--消息中间件接口--发送队列--通道代理--网络--通道代理--接收队列--消息中间件接口--应用程序B

 																					SUB1（订阅-->确认）      缓存      （L2 cache）                  
 																					SUB2     	               论坛                  
  PUB（用户信息更新）  主题A-->（投递）
  																				SUB3       
 																					SUB4      			         热点数据缓存		（L1 cache）
 																					
 																		
互联网消息中间件应用场景：
1、网站用户注册、用户密码找回
	 填写注册信息-->用户注册服务-->消息中间件-->邮件服务
	                                         -->短信服务
	 PUB-SUB模式  持久订阅（短信服务：设置30分钟有效时间）
2、把日志进行集中收集，用于计算PV、用户行为分析（消息中间件进行缓冲、收集（监控网络、负载）、存储的角色）
   后台进行数据分析（恶意刷单人）。
3、数据复制案例：
4、压测：1）把消息中间件当做可靠的消息暂存地
				 2）定时消息投递，模拟用户访问，进行系统性能压测
5、消息广播：1）缓存数据同步更新
						 2）往应用推送数据（发布订阅模式  持久化订阅）  比如更新本地数据：
						   												cache
						 数据变更-->消息中间件    cache
                                      cache


分类：

　　

简介：Message MiddleWare消息中间件是在消息的传递过程中保存消息的容器。消息中间件再将消息从它的源中继到它的目标时，充当中间人的作用。
消息包括：订单信息等，需要消费者处理的东西
特点：1）异步处理模式  发送者发送消息而无需等待响应。消息发送者将消息发送到一条虚拟的通道上，消息接受者则订阅或监听该通道。                 一条消息可能最终转发给一个或者多个消息接收者，这些消息接收者无需对消息发送者做出同步回应。整个过程是异步的2）松耦合 发送者和接受者不必了解对方 只需要确认消息发送者和接受者不必同时在线
消息传递服务模型：
点对点模型PTP：点对点模型用于生产者消费者之间的点到点的通信  队列消息可放在内存中也可以是持久的。 特性：1）只有一个消费者 2）没有时间依赖 3）接受者确认消息和接收处理请求  发布-订阅模型Pub-Sub：TOPIC 订阅者发布者模型支持向一个特定的消息主题生产消息特性：1）每个消息可以有多个订阅者2）订阅后才能接收到消息3）持久订阅和非持久订阅（持久订阅：订阅方重启后，发布方会重新发消息给订阅方，互联网公司常用。比如支付场景，要求强一致性的业务。 非持久订阅：重启后，不会重新发消息，通知消息，一致性要求不高）    4）时间依赖 只有建立订阅关系才能接受消息    5）持久订阅：关系建立后，消息不会消失，不管订阅者是否在线    6）非持久订阅：订阅者为了接受消息，必须一直在线        消息中间件过程：
应用程序A--消息中间件接口--发送队列--通道代理--网络--通道代理--接收队列--消息中间件接口--应用程序B
 SUB1（订阅-->确认）      缓存      （L2 cache）                   SUB2                   论坛                    PUB（用户信息更新）  主题A-->（投递）  SUB3        SUB4               热点数据缓存（L1 cache）  互联网消息中间件应用场景：1、网站用户注册、用户密码找回 填写注册信息-->用户注册服务-->消息中间件-->邮件服务                                         -->短信服务 PUB-SUB模式  持久订阅（短信服务：设置30分钟有效时间）2、把日志进行集中收集，用于计算PV、用户行为分析（消息中间件进行缓冲、收集（监控网络、负载）、存储的角色）   后台进行数据分析（恶意刷单人）。3、数据复制案例：4、压测：1）把消息中间件当做可靠的消息暂存地 2）定时消息投递，模拟用户访问，进行系统性能压测5、消息广播：1）缓存数据同步更新 2）往应用推送数据（发布订阅模式  持久化订阅）  比如更新本地数据：   cache 数据变更-->消息中间件    cache                                      cache

分类：