什么是jms
jms(java message service) Java消息服务, jms是一种规范是jdk底层定义的, 各大厂商对这个规范都是实现的技术.
jms作用:
在分布式系统当中, 系统和系统之间进行异步消息传递.
同步通讯技术:
代表的技术有: dubbo, springCloud, webService
技术特点: 例如controller中调用多个service, 每个service的执行要等待上一行代码执行完成后才会继续执行
下一行代码.
优点: 实时性比较好, 因为controller调用service, 然后service就去立即执行
缺点: 执行速度慢, 因为代码执行的顺序是串行执行, 下一行的代码执行要等待上一行代码执行完成后方可执行.
异步通讯技术:
代表的技术有: jms一系列的, activemq, rabbitmq, rokitmq, zeromq, kafka等
技术特点: 例如controller将消息发送给消息服务器, 消息服务器接收到消息后, 会以广播的形式发给其他处理
具体业务的服务器. 其他具体处理业务的服务器接收到消息后就会根据消息完成工作.
优点: 将以前串行执行的业务可以改为并行执行, 处理速度会比以前快, 能够更合理的分配每台计算机的性能.
缺点: 如果消息服务器正处于繁忙状态, 那么处理发消息的任务可能不及时. 所以对实时性要求不高的业务可以使用
这个技术.
消息中间件技术分类:使用的时候用封装之后的jmsTemplet,它是spring全家桶的一份子,不论使用哪一个他们底层都是调用的各自的客户端工具包,所有会使用一个其他的都可以使用了
activeMq: 是apache公司的, 一个老牌的消息中间件, 性能均衡, 不是最快的, 传递数据的安全性也不是最好的.
RabbitMQ: 阿里巴巴公司生产的, 它比较安全. 因为这个中间件有分布式消息级别事务功能.
ZeroMQ: 史上最快的队列系统
Kafka: 史上最快的消息中间件技术, 可以达到单机每秒10万的吞吐量
消息中间件支持的传输数据对象的类型:
TextMessage--一个字符串对象
MapMessage--一套名称-值对
ObjectMessage--一个序列化的 Java 对象
BytesMessage--一个字节的数据流
StreamMessage -- Java 原始值的数据流
消息中间件支持的两种发送模式:
点对点(Queue): 一个消息发送方, 一个消息接收方. 相当于qq的私聊
如果是多个发送方, 一个接收方也算点对点模式
订阅发布模式(Topic): 一个消息发送方, 多个消息接收方. 相当于qq的群聊.
如果多个发送方, 多个接收方也算发布订阅模式
activeMq中保证数据安全性机制(保证数据不会丢):
点对点模式:
a. 发送方将数据发送给消息服务器, 进入消息服务器中的队列
b. 消息服务器接收到消息后会从队列中将数据发送给接收方
c. 如果接收方接收到数据后, 会返回响应给消息服务器, 消息服务器接收到响应后认为接收成功
这个时候会将这个数据从队列中删除
d. 如果接收方处于宕机状态, 无法接收到数据, 那么也就无法返回响应给消息服务器, 消息服务器在
一段时间后没有接受到接收方的响应, 则会认为消息接收方宕机, 会将数据从队列中拿出来进行持久化
保存到消息服务器的硬盘中, 每个一段时间会发送给消息接收方一次. 直到接收到消息接收方的响应
则会认为发送成功, 将持久化的数据删除