Kafka是一个比RabbitMQ更加强大的消息中间件，处理消息的能力为80-100M/s，下面安装记录一下，Linux版本为Centos6。 解压压缩包 直接解压即可。 [root@hadoop01 /home/software]# tar -zxvf kafka_2.11-1.0.0.tgz 修 ...
分类：
其他好文 时间：
2019-12-30 23:19:06
阅读次数：
92
@Component @RabbitListener(queues="my_fanout") public class Consumer { @RabbitHandler public void process(String msg){ System.out.println(msg); } } 但是 ...
分类：
编程语言 时间：
2019-12-30 19:20:34
阅读次数：
90
消费端限流 什么是消费端的限流？ 假设一个场景，首先，我们RabbitMQ服务器有上万条未处理的消息，我们随便打开一个消费者客户端，会出现下面情况： 巨量的消息瞬间全部推送过来，但是我们单个客户端无法同时处理这么多数据！ 消费端限流RabbitMQ提供的解决方案 RabbitMQ提供了一种qos（服 ...
分类：
其他好文 时间：
2019-12-30 14:26:38
阅读次数：
106
消息队列 为什么写这篇文章? 博主有两位朋友分别是小A和小B: 小A，工作于传统软件行业(某社保局的软件外包公司)，每天工作内容就是和产品聊聊需求，改改业务逻辑。再不然就是和运营聊聊天，写几个SQL，生成下报表。又或者接到客服的通知，某某功能故障了，改改数据，然后下班部署上线。每天过的都是这种生活， ...
分类：
其他好文 时间：
2019-12-30 11:20:33
阅读次数：
71
前言 RabbitMQ是一个开源的消息中间件，采用 语言进行编写，因此RabbitMQ的安装需要依赖Erlang，现在我们将在 下进行安装RabbitMQ。 本人环境：CentOS 6.5 64位 安装Erlang 在安装Erlang的时候，有很多种方法，最开始我是想按照官网先下载Erlang安装包 ...
分类：
系统相关 时间：
2019-12-29 13:07:33
阅读次数：
117
任务队列（中间人）用的是redis，也可以用别的,如RabbitMQ数据库 如果任务处理者没有运行django项目只是运行了celery（如果运行了django项目则不需要），则需要在celery的配置中添加上一下配置，使其产生django环境来运行： 汇总： ...
分类：
其他好文 时间：
2019-12-28 19:11:08
阅读次数：
49
RabbitMQ服务器安装1、安装erlang 2、安装RabbitMQ 3、 常用命令 4、 浏览器打开 端口号默认:15672<br/>密码和用户名默认:guesthttp://127.0.0.1:15672/#/5、常见错误错误提示:zsh: command not found: rabbit ...
分类：
其他好文 时间：
2019-12-28 17:42:54
阅读次数：
68
http://tryrabbitmq.com/ ...
分类：
编程语言 时间：
2019-12-28 16:26:49
阅读次数：
40
RabbitMQ队列延迟 1. 场景： “订单下单成功后，15分钟未支付自动取消” 1.传统处理超时订单 采取定时任务轮训数据库订单，并且批量处理。其弊端也是显而易见的；对服务器、数据库性会有很大的要求， 并且当处理大量订单起来会很力不从心,而且实时性也不是特别好。当然传统的手法还可以再优化一下， ...
分类：
其他好文 时间：
2019-12-28 13:06:39
阅读次数：
93
前言前一阵开发过程遇到的问题，用的rabbitmqtemplate发送消息，消息body里的时间是比当前时间少了8小时的，这种一看就是时区问题了。就说说为什么出现吧。之前的配置是这样的：@BeanpublicRabbitTemplaterabbitTemplate(ConnectionFactoryconnectionFactory){RabbitTemplatetemplate=newRabbi
分类：
其他好文 时间：
2019-12-27 19:46:46
阅读次数：
113
