背景:python的Queue消息队列,只能python自己用。 --线程threading Queue 只能在一个进程间交互数据 --进程Queue最多可以父进程和多个子进程进行交互 常见队列工具:RabbitMQ、ZeroMQ、ActiveMQ RabbitMQ 使用erlang语言开发的。 P ...
分类:
其他好文 时间:
2018-08-11 23:22:55
阅读次数:
197
一,springCloud集成eureka,搭建注册中心 代码地址:https://github.com/gebifeixiang/eureka-center 踩坑点: 二,springCloud集成eureka,mysql,mybatis,activeMq,redis 代码地址; 数据处理服务层; ...
分类:
编程语言 时间:
2018-08-11 19:34:29
阅读次数:
186
在本节中,我们将学习如何编写一个简单的测试计划来测试Java Messaging Service(JMS)。 出于测试目的,我们使用Apache ActiveMQ。有各种JMS服务器,如:glassfish3,IBM WebSphere MQ(以前称为MQSeries),Tibco等。 在继续本节之 ...
分类:
其他好文 时间:
2018-08-10 21:26:24
阅读次数:
334
1、在pom文件中引入对应jar包 2、application.yml文件配置activemq;对于监听Listener使用注解的形式 3、创建生产者类,生产者代码如下: 4、编写消费者代码,代码如下: 5、运行生产者(本处是test注解的测试代码),直接运行,结果如下 发送端: 接收端: ps:如 ...
分类:
编程语言 时间:
2018-08-10 19:52:10
阅读次数:
240
一、使用场景: mysql数据库字段类型为longblob,在数据库里看中文字符正常,java读取字串的时候发现中文乱码 使用到了activeMq 二、排查: (1)修改eclipse的环境编码为utf-8 (2)怀疑是mq读取转码,修改mq的配置文件,指定字符集编码 三、解决: longblob是 ...
分类:
数据库 时间:
2018-08-10 12:28:40
阅读次数:
254
subscribe($queue); while(true) { //判断是否有读取的信息 if($stomp->hasFrame()) { $frame = $stomp->readFrame(); $data = json_decode($frame->body, true); //保存原始接收... ...
分类:
其他好文 时间:
2018-08-09 12:19:57
阅读次数:
269
目前的架构: 负载均衡方案: 第二种方案呢,假设我们整个应用是个食堂,这个食堂里面有好多饭口,每个饭口有好多大爷大妈(咦~~~)。每个饭口实现了高可用,即使有大妈不上班,还有大爷顶上。针对好多学生(用户),实现了负载均衡,学生被基本均匀的分配到每一个饭口上。 食堂 应用 饭口 集群 大妈 服务器 现 ...
分类:
其他好文 时间:
2018-08-07 13:06:57
阅读次数:
144
一、xml配置形式 1、在Spring配置文件中增加面向切面配置当调用com.activemq.service.impl.ConsumerServiceImpl接口实现类的任意方法时执行切面类中的方法。 2、写切面类 注意:1)不能对web层(比如:com.activemq.action.Consu ...
分类:
编程语言 时间:
2018-08-07 01:37:18
阅读次数:
210
阿里P8架构师谈:消息中间件介绍、典型使用场景、以及使用原则大型分布式架构里一定会涉及到消息中间件,今天先谈谈消息中间件。本文作者陈睿优知学院创始人曾任职阿里巴巴高级软件工程师、百度研发经理、携程定制旅游CTO常用的消息队列有ActiveMQ,RabbitMQ,ZeroMQ,Kafka,MetaMQ,RocketMQ。一、kafka1、不完全符合jms规范,注重吞吐量,类似udp和tcp2、一般做
分类:
其他好文 时间:
2018-08-06 16:28:43
阅读次数:
181
package com.mq.test.activeMQ; import java.text.DateFormat; import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Calend... ...
分类:
编程语言 时间:
2018-08-05 21:33:40
阅读次数:
172