常见的异步事件处理框架有:node.jsnettyakkadisruptor消息服务器:zeromq,rabbitmq,kafka,activemq缓存服务器:redismemcachemongodb负载均衡:lvs+nginx
分类:
其他好文 时间:
2015-12-29 22:28:58
阅读次数:
218
ActiveMQ的另一种模式就SUB/HUB即发布订阅模式,是SUB/hub就是一 拖N的USB分线器的意思。意思就是一个来源分到N个出口。还是上节的例子,当一个订单产生后,后台N个系统需要联动,但有一个前提是都需要收到订单信 息,那么我们就需要将一个生产者的消息发布到N个消费者。生产者: ...
分类:
其他好文 时间:
2015-12-25 16:58:33
阅读次数:
143
ActiveMQ的另一个问题就是只要是软件就有可能挂掉,挂掉不可怕,怕的是挂掉之后把信息给丢了,所以本节分析一下几种持久化方式:一、持久化为文件ActiveMQ默认就支持这种方式,只要在发消息时设置消息为持久化就可以了。打开安装目录下的配置文件:D:\ActiveMQ\apache-activemq...
分类:
其他好文 时间:
2015-12-25 16:48:31
阅读次数:
273
1.ActiveMQ简介先分析这么一个场景:当我们在网站上购物时,必须经过,下订单、发票创建、付款处理、订单履行、航运等。但是,当用户下单后,立即跳转到“感谢那您 的订单” 页面。不仅如此,若果没有延迟,用户还会受到一封电子邮件。如果我们使用传统方式去实现,一般是对数据库操作一通,然后调用各种接口、...
分类:
Web程序 时间:
2015-12-25 16:40:57
阅读次数:
201
一、配置部分二、代码部分三、页面部分四、Controller控制器五、效果展示六、加入监听器七、最最重要的,别忘了打赏一、配置部分ActiveMQ的安装这就不说了,很简单,这个例子采用maven构建,首先看一下pom.xml 4.0.0 com.gzframe.demo gzframe ...
分类:
编程语言 时间:
2015-12-25 13:37:46
阅读次数:
389
1.1JMS简介JMS的全称是Java Message Service,即Java消息服务。它主要用于在生产者和消费者之间进行消息传递,生产者负责产生消息,而消费者负责接收消息。把它应用到实际的业务需求中的话我们可以在特定的时候利用生产者生成一消息,并进行发送,对应的消费者在接收到对应的消息后去完成...
分类:
编程语言 时间:
2015-12-25 11:28:38
阅读次数:
213
一、概述本教程主要阐释了如何利用SignalR与消息队列的结合,实现不同客户端的交互SignalR如何和消息队列交互(暂使用ActiveMQ消息队列)SignalR寄宿在web中和其他SignalR、控制台客户端交互。SignalR单独寄宿在控制台中和其他SignalR、控制台客户端交互。下面屏幕截...
分类:
其他好文 时间:
2015-12-24 02:07:14
阅读次数:
398
一. 开篇语继上一篇apache ActiveMQ之初体验后, 由于近期一直在复习spring的东西, 所以本文就使用spring整合下JMS.二. 环境准备1. ActiveMQ5.2.0 (activemq-all-5.2.0.jar)2. spring2.5 (spring.jar)3. Ja...
分类:
编程语言 时间:
2015-12-23 12:30:03
阅读次数:
196
docker运行activemq,日志时间和容器时间如下:d我执行date命令隔了几分钟,由时间上发现正好差了8个小时,怀疑还是时区的原因.2.疑惑有好友称,讲宿主机的/etc/locatime挂载到容器中,就会解决此问题.可是得到的结果是依然是上图.3.查询资料,请教大神,得到结果在java应用启动前,添加..
分类:
编程语言 时间:
2015-12-17 16:25:08
阅读次数:
253
SpringMVC+MyBatis 相信已经是现在企业开发中常用技术了。
因为一些需求,我们需要集成JMS(我使用的是ActiveMQ),大家应该都知道,MQ也可以认为是一个数据源,数据也是数据源。这种情况下,如果我们在一个方法内操作JMS和数据库,我们就需要保证这个方法执行需要满足原子性。
这也就意味这一个问题,我们要多个数据源在同一个事务中。这里不枚举市面上的所有解决方案,其实atomiko...
分类:
编程语言 时间:
2015-12-17 10:54:57
阅读次数:
288