封装一个task到一个message,并发送到queue。consumer会去除task并执行这个task。 这里我们简化了操作,发送消息到队列中,consumer取出消息计算里面'.'号有几个就sleep几秒。 task.py work.py 代码解释 ...
分类:
其他好文 时间:
2017-01-12 22:52:02
阅读次数:
198
前言:作为一个运维人员不背锅,谁背呢!正文:网上都是2种办法去实现,第二种我就不说了,要升级rabbitmq别人也说什么什么不行好吧~今天按照网上说的TTL+DLX的方式来实现延迟消息(java的python的相关代码都有就是没有拍huang片的!!!!)撸代码咯:1.首先得要创建一个新的队..
分类:
Web程序 时间:
2017-01-12 03:21:36
阅读次数:
354
下面我们通过几个实例测试下mandatory标志的作用:
测试1:设置mandatory标志,且exchange未绑定队列
public class ProducerTest {
pu...
分类:
其他好文 时间:
2017-01-10 21:41:25
阅读次数:
3031
Rabbitmq是基于erlang开发的消息队列,客户端支持主流的开发语言(java、C#、Python等)。 环境:windows server 2012(x64) 1、下载安装 http://www.erlang.org/downloads 下载安装erlang运行环境(OTP) http:// ...
Routing 之前的章节里我们构建了一个简单的日志系统。我们可以广播所有的日志消息给所有的接收端。 本节我们将给它添加一个新特性 - 我们将允许只订阅一个消息的子集。例如,我们只将关键的错误消息定位到文件中(以节省磁盘空间),同时仍然可以在控制台输出所有日志消息。 Bindings 在前面的例子中 ...
分类:
其他好文 时间:
2017-01-09 10:04:49
阅读次数:
227
前言 最近项目要使用RabbitMQ,园里里面已经有很多优秀的文章,Rabbitmq官网也有.net实例。这里我尝试下图文并茂之形式记录下使用的过程。 安装 RabbitMQ是建立在erlang OTP平台下,因此在windows下需要下载并安装以下两个组件: 1. Erlang OTP For w ...
分类:
Web程序 时间:
2017-01-08 20:11:33
阅读次数:
226
vhost配置<VirtualHost*:80>DocumentRoot"/tmp/tmp"ServerNametmp.com<Directory/tmp/tmp/>Orderallow,denyDenyfromall</Directory></VirtualHost><VirtualHost*:80>DocumentRoot"/data/www"ServerNamewww.1.comServerAliaswww.a.comwww.b.comSe..
分类:
Web程序 时间:
2017-01-08 08:26:00
阅读次数:
6240
RabbitMQ的集群方案有以下几种: 1.普通的集群 exchange,buindling再所有的节点上都会保存一份,但是queue只会存储在其中的一个节点上,但是所有的节点都会存储一份queue的meta信息。因为这样有两个好处: 1)存储空间。如果每一个节点上都有全部的消息,有多少个节点就会有 ...
分类:
其他好文 时间:
2017-01-05 09:59:00
阅读次数:
443
自己配置的XWAMP环境,默认下没有详细配置mysql的my.ini,一方面不同服务器的配置不一样,另一方面按照默认为空的方式也一直没有出现过问题。不过最近服务器挂掉了,出现的症状是: 网站不能打开,动态的。静态的可以。不能远程桌面。 强制重启服务器后查看系统日志发现了这个错误: mysqld: O ...
分类:
数据库 时间:
2017-01-05 09:51:25
阅读次数:
207
记录一次RabbitMQ配置文件配置错误 error信息: dill@ubuntu-vm:/usr/share/doc/rabbitmq-server$ sudo /usr/lib/rabbitmq/bin/rabbitmq-server {"could not start kernel pid", ...
分类:
其他好文 时间:
2017-01-03 20:36:19
阅读次数:
387