针对公司业务逻辑,向阿里云MQ发送指定数据,消费端根据数据来做具体的业务,分两个项目,一个生产端(Producer)、一个消费端(Consumer) 生产端通过定时任务执行sql向阿里云MQ发送数据,消费端消费指定Topic上的数据 1:定时任务列表: 2:生产端表结构: aliasName:定时任 ...
分类:
其他好文 时间:
2016-09-30 12:30:12
阅读次数:
613
阅读目录 定义 优秀MQ特点 产品比较 实例(简单的实战) 定义: 消息队列(MQ)是一种应用程序对应用程序的通信方法,应用程序通过队列进行通信,而不是通过直接调用彼此来通信,队列的使用除去了接收和发送应用程序同时执行的要求。 PS:直接调用通常是用于诸如远程过程调用的技术。 优秀MQ特点 a>.高 ...
分类:
其他好文 时间:
2016-09-26 19:38:58
阅读次数:
125
rabbitMQ是一个在AMQP协议标准基础上完整的,可服用的企业消息系统。它遵循Mozilla Public License开源协议,采用 Erlang 实现的工业级的消息队列(MQ)服务器,Rabbit MQ 是建立在Erlang OTP平台上。 1.安装Erlang 所以在安装rabbitMQ ...
在消费者接受队消息时,出现异常 javax.jms.JMSException: Failed to build body from content. Serializable class not available to broker. Reason: java.lang.ClassNotFound ...
分类:
其他好文 时间:
2016-09-23 14:46:11
阅读次数:
182
一、测试环境搭建 1.第一次搭建环境: 1)安装依赖文件 2)获取源代码,编译 3)导入基础数据 4)修改配置文件,如数据库地址,redis地址,mq地址 5)启动web服务器 Java:tomcat、weblogic、webshare、jetty Php:nginx、apache 2.部署、发版过 ...
分类:
数据库 时间:
2016-09-21 20:00:11
阅读次数:
310
对于分布式网络环境或者有大量任务的应用,我们需要将任务在不同的服务器之间进行分布,这个时候正好是Gearman发挥实力的时候。虽然我们也可以使用MQ队列再加一些自己实现的调度算法来将任务进行分发,但是既然已经有了成熟的产品,为什么不使用下呢。 Gearman介绍 Gearman提供了一种通用的程序框 ...
分类:
其他好文 时间:
2016-09-21 10:22:45
阅读次数:
167
业务背景在内存中,对mq消息进行分类计数。问题描述生产环境,运行一段时间后,发现消息队列有大量堆积。如果把计数逻辑注释掉,只接收用户访问消息而不进行处理,则mq队列无堆积。mq栈dump信息如下:ConsumeMessageThread_75TID:214STATE:WAITINGConsumeMessageThread_75sun.m..
分类:
其他好文 时间:
2016-09-19 22:46:46
阅读次数:
1212