
(1)、客户接收消息;(2)、客户处理消息;(3)、消息被确认;
确认机制前面提过一下,共有四种:
(1)、Session.AUTO_ACKNOWLEDGE;客户(消费者)成功从receive方法返回时,或者从MessageListener.onMessage方法成功返回时,会话自动确认消息,然后自动删除消息.
(2)、Session.CLIENT_ACKNOWLEDGE;客户通过显式调用消息的acknowledge方法确认消息,。activemq api开发文档即在接收端调用message.acknowledge();方法,否则,消息是不会被删除的.
(3)、Session. DUPS_OK_ACKNOWLEDGE ;不是必须确认,是一种“懒散的”消息确认,消息可能会重复发送,在第二次重新传送消息时,消息头的JMSRedelivered会被置为true标识当前消息已经传送过一次,客户端需要进行消息的重复处理控制。activemq api开发文档
(4)、 Session.SESSION_TRANSACTED;事务提交并确认。
2.8 ActiveMQ持久化消息与非持久化消息
(3)持久化:memcache不支持持久化,redis支持持久化。2. 在master侧禁用数据持久化,只需在slave上配置数据持久化。a、全量持久化rdb(遍历redisdb,读取bucket中的key,value),save命令阻塞主线程,bgsave开启子进程进行snapshot持久化操作,生成rdb文件。
messageProducer.setDeliveryMode(DeliveryMode.
PERSISTENT);//持久化的,当然activemq发送消息默认都是持久化的
说明:
设置完后,如果为持久化,那么消息在没有被消费前都会被写入本地磁盘kahadb文件中保存起来,即使服务器宕机,也不会影响
消息.如果是非持久化的,那么,服务一旦宕机之类的情况发生,消息即会被删除.
ActiveMQ默认是持久化的.
2.9 ActiveMQ消息过滤
采用全新设计的国际eia标准全u金属机箱,装配银灰色系的控制面板,以清晰明亮的led显示接收操作讯息,后面板装置具有提供偏压的天线座,可以连接同轴天线或外接强波器及延长天线,能加装分配器,提供多频道共享天线,提升接收距离及讯号质量,获得最佳的接收效果。内容20分等级:一等标准:切合题意,中心突出,内容充实,感情真挚等级:二等标准:符合题意,中心明确,内容较充实,感情真挚等级:三等标准:基本符合题意,中心基本明确,内容单薄,感情基本真实等级:四等标准:偏离题意,中心不明确,内容不当,感情虚假表达20分等级:一等标准:符合文体要求,结构严谨,语言流畅,字体工整等级:二等标准:基本符合文体要求,结构完整,语言通顺,字体较工整等级:三等标准:大体符合文体要求,结构基本完整,语言基本通顺,字迹清楚等级:四等标准:不符合文体要求,结构混乱,语言不通顺。涂层颜色: 根据用户需求选择(常孔间横向距离a12实验研究、经验总结和规范的编制与完善新 风必须严格过滤,为此在进风口加装了中效过滤器和亚过滤器,新风过滤后含尘量 小于 1.5mgnm3。您的卡片被盗或遗失,即可通过电话等方式挂失,经确认后挂失即时生效,如您没有美元活期存款账户或美元活期存款账户余额不足时,我行将根据您的选择提供购汇功能、外汇买卖及账户管理等功能。
生产者可在消息中放入特有的标志,而消费者使用基于这些特定的标志来接收消息;
本文来自电脑杂谈,转载请注明本文网址:
http://www.pc-fly.com/a/jisuanjixue/article-94236-8.html
用以练手
驸马都尉是武汉大学中文出身的文科生