消息服务是以消息为载体,在各应用系统之间进行传递共享的异步数据系统。
消息结构:消息标头、消息属性和消息主体
消息头信息JMS目标
JMSDeliveryMode
JMS消息id
JMSTimestamp
JMS表达式
JMSRedelivered
日本航空母舰
JMSReplyTo
JmsCorrelationId
JMSType
自定义消息属性信息:
String、boolean、byte、double、int、long、float
JMS定义:
JMSXGroupID
JMSXGroupSeq等
消息主体类型TextMessage
流消息
地图消息
对象消息
BytesMessage
为什么要使用消息服务? 1 .异构集成
2 .缓解系统瓶颈
3 .提高可扩展性
4 .提高最终用户工作效率
5 .架构灵活敏捷
6.ip活跃
消息传递模型点对点模型
发布订阅模型
将两种传输模式转换为
点对点模型消息通过队列进行交换
每封邮件最多只能有一个收件人
消息有优先级
生产和消费者没有结合起来
模型消息的发布/订阅将通过主题进行交换
各消息传递给多个收件人
发送者不知道也没有意识到正在接收消息的订阅者的数量
发布者通过主题将消息复制的副本发布给所有订阅该主题的订阅者
JMS应用程序连接工厂
目的地
连接
会话
消息
消息产品
MessageConsumer
消息服务流程
点对点APIQueueConnectionFactory
队列
队列连接
队列会话
消息
队列发送器
QueueReceiver
发布/订阅APITopicConnectionFactory
东京大学
主题连接
主题会话
消息
TopicPublisher
TopicSubscriber
消息过滤器
消费者可根据条件过滤所需要的消息类型,这样不仅仅可以提高消息准确性灵活性,还可以保持消息不会被无用的消费者所消费,消息过滤器语法同sql语法。
服务APP应用程序是否深入到JMS集群的构建和负载均衡中?
实现ActiveMq分布式事务控制?
ActiveMq数据持久性?
恢复ActiveMq数据?