Kafka是当下对海量数据提供了最佳支持的MQ中间件，无论是高并发的处理，还是依托zookeeper的水平拓展都有不俗的特性。由于公司最近也在尝试如何将它应用到开发中以对业务更好的支撑，因此特地分享一些安装和使用的心得。 一、安装与启动 服务器环境采用CentOS 7 x64位系统。实际使用中Kaf ...
分类：
其他好文 时间：
2018-12-22 18:29:08
阅读次数：
209
介绍 MQ全称为Message Queue, 是一种分布式应用程序的的通信方法，它是消费-生产者模型的一个典型的代表，producer往消息队列中不断写入消息，而另一端consumer则可以读取或者订阅队列中的消息。RabbitMQ是MQ产品的典型代表，是一款基于AMQP协议可复用的企业消息系统 系 ...
分类：
其他好文 时间：
2018-12-20 14:15:39
阅读次数：
247
使用pika库操作rabbit 查找whereis rabbitmq-server 启动/usr/sbin/rabbitmq-server & 打印了一些rabbitmq服务状态信息，包括内存，硬盘，和使用erlong的版本信息rabbitmqctl -q status 查看所有队列消息rabbit ...
分类：
其他好文 时间：
2018-12-19 15:38:57
阅读次数：
145
（十七）JAVA springcloud ssm b2b2c多用户商城系统-消息驱动 Spring Cloud Stream 1. 简介： Spring cloud Stream 数据流操作开发包，封装了与Redis,Rabbit、Kafka等发送接收消息。 2. 使用工具： rabbit，具... ...
分类：
编程语言 时间：
2018-12-19 11:09:24
阅读次数：
171
最近工作中接到一个需求，需要对一个MQ消息队列进行性能测试，测试其消费能力，开发提供了一个dubbo服务来供我调用发送消息。 这篇博客，介绍下如何利用jmeter来测试dubbo接口，并进行性能测试。。。 一、Dubbo简介 dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调 ...
分类：
其他好文 时间：
2018-12-19 11:04:27
阅读次数：
173
创建用户 rabbitmqctl add_user kye01 123456 设置用户角色 rabbitmqctl set_user_tags kye01 monitoring 查看用户清单 rabbitmqctl list_users 给用户授权 rabbitmqctl set_permissio ...
分类：
其他好文 时间：
2018-12-18 16:00:32
阅读次数：
184
什么是可靠消息？ 为什么我们需要它，为什么我们要强调可靠？ 生产方 消息发送出去了，如果生产方收到了消息的正常反馈，那么我们就可以知道消息的确切的状态。 如果消息无响应 或者超时了呢？ 有多个情况， 1 消息未到达mq，发送途中 就某些原因丢失了， 2 消息送达mq，但是mq处理未完成就丢失（这里又 ...
分类：
其他好文 时间：
2018-12-16 11:09:21
阅读次数：
128
<!-- 集中定义依赖版本号 --> <properties> <junit.version>4.10</junit.version> <spring.version>4.1.3.RELEASE</spring.version> <mybatis.version>3.2.8</mybatis.ver ...
分类：
其他好文 时间：
2018-12-15 13:57:53
阅读次数：
140
1、POM引入spring-cloud-starter-stream-rabbit 注意springboot 版本，用1.5.2.RELEASE 就报错 rabbitmqTemple not found sb版本切换到1.5.14 就好了 <parent> <groupId>org.springfr ...
分类：
编程语言 时间：
2018-12-14 12:45:36
阅读次数：
1193
ActiveMQ简介 MQ是消息中间件，是一种在分布式系统中应用程序借以传递消息的媒介，常用的有ActiveMQ，RabbitMQ，kafka。ActiveMQ是Apache下的开源项目，完全支持JMS1.1和J2EE1.4规范的JMS Provider实现。消息类型包括点对点（queue），一对多 ...
分类：
其他好文 时间：
2018-12-13 16:25:27
阅读次数：
268
