ConnectionFactory是用于产生到JMS服务器的链接的,Spring为我们提供了多个ConnectionFactory,有SingleConnectionFactory和CachingConnectionFactory。SingleConnectionFactory对于建立JMS服务器链... ...
分类:
编程语言 时间:
2017-06-22 23:48:04
阅读次数:
306
Broker可以被看成消息转发器。Broker也负责一些控制和管理操作。它能够定位服务端的位置,若发生异常,能够将异常捕获传给Client。Broker需要提供注册服务的接口给Server。如果请求来自其他的Broker,本地的Broker需要转发请求并最终将结果或异常回应给相应的远程Broker。... ...
分类:
其他好文 时间:
2017-06-22 20:52:20
阅读次数:
159
一、消息的存储方式ActiveMQ支持JMS规范中的持久化消息与非持久化消息持久化消息通常用于不管是否消费者在线,它们都会保证消息会被消费者消费。当消息被确认消费后,会从存储中删除非持久化消息通常用于发送通知以及实时数据,通常要求性能优先,消息可靠性并不是必须的情况MQ..
分类:
其他好文 时间:
2017-06-22 16:43:50
阅读次数:
203
switch(args[0][0]) //解析指令,看每个指令对应哪些意思 { case 'd': //display switch(args[1][0]) { case 'q': //display queue show_MQ(fd); break; case 'd': //display deb ...
分类:
系统相关 时间:
2017-06-21 18:25:19
阅读次数:
201
假设有文件长如下样子: CHROM POS ID REF ALT QUAL FILTER INFO FORMAT samplename 1 3552841 . G . 32.995 . DP=1;MQ0F=0;AF1=0;AC1=0;DP4=1,0,0,0;MQ=40;FQ=-29.9912 GT: ...
分类:
系统相关 时间:
2017-06-20 23:51:43
阅读次数:
548
从ActiveMQ 5.6版本之后,又推出了LevelDB的持久化引擎。目前默认的持久化方式仍然是KahaDB,不过LevelDB持久化性能高于KahaDB,可能是以后的趋势。在ActiveMQ 5.9版本提供了基于LevelDB和Zookeeper的数据复制方式,用于Master-slave方式的... ...
分类:
其他好文 时间:
2017-06-18 14:25:54
阅读次数:
273
ActiveMQ支持的client-broker通讯协议有:TCP、NIO、UDP、SSL、Http(s)、VM。 其中配置Transport Connector的文件在activeMQ安装目录的conf/activemq.xml中的
...
分类:
其他好文 时间:
2017-06-18 10:26:00
阅读次数:
191
之前在讲RPC通信的各种好处,特别好用,但是RPC并不是万能的,也并不是适用于各种场景的,因为他是同步的;现如今很多场景下的调用都是异步的,系统A调用B后,并不需要知道B的结果,而且对B的结果无所谓,甚至你B挂了都无所谓,那么这个时候使用消息队列是十分OK的。 最简单的场景就是发送短信和email, ...
分类:
其他好文 时间:
2017-06-14 21:17:47
阅读次数:
194
RabbitMQ实例详解 消息队列中间件是分布式系统中重要的组件,主要解决应用解耦,异步消息,流量削锋等问题,实现高性能,高可用,可伸缩和最终一致性架构。 Queue Queue(队列)是RabbitMQ的内部对象,用于存储消息,用下图表示。 RabbitMQ中的消息都只能存储在Queue中,生产者 ...
分类:
编程语言 时间:
2017-06-14 13:15:19
阅读次数:
1287
参考了其他博主的资料,整理成完整的代码,直接拷贝就可以测试。 一、创建一个properties文件 mq.vhost表示rabbitMQ虚拟主机,类似一台电脑里面划分了多个虚拟主机,每个虚拟主机都可以有交换器,队列,感觉又类似于一种命令空间。 创建的虚拟主机的可以使用rabbitMQ的工具rabbi ...
分类:
编程语言 时间:
2017-06-11 16:30:25
阅读次数:
269