消息中间件利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。通过提供消息传递和消息排队模型，它可以在分布式环境下扩展进程间的通信。对于消息中间件，常见角色大致也就有 Producer（生产者）、Consumer（消费者）。 常见的消息中间件产品: 1). Act ...
分类：
其他好文 时间：
2020-10-12 20:42:58
阅读次数：
31
将队列和交换器绑定的方法如下，可以与前两节中的方法定义(exchangeDeclare和queueDeclare)进行类比。 1.Queue.BindOk queueBind(String queue, String exchange, String routingKey) throws IOExc ...
分类：
其他好文 时间：
2020-10-12 20:34:35
阅读次数：
28
[root@jinkang-e2elog rabbitmq]# cat topic-send.py #!/usr/bin/env python # -*- coding: UTF-8 -*- import pika import sys connection = pika.BlockingConne ...
分类：
其他好文 时间：
2020-10-09 21:38:16
阅读次数：
40
介绍 RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件。主要用来做异步处理、应用解耦、流量削峰、日志处理等等方面的处理。 特点 可靠性: RabbitMQ使用一些机制来保证可靠性， 如持久化、传输确认及发布确认等。 灵活的路由 : 在消息进入队列之前，通过交换器来路由消息。对于... ...
分类：
其他好文 时间：
2020-10-07 20:24:27
阅读次数：
25
#include <queue> #include <cstdlib> #include <cmath> #include <cstdio> #include <string> #include <cstring> #include <iostream> #include <algorithm> u ...
分类：
其他好文 时间：
2020-10-06 20:54:49
阅读次数：
33
服务器介绍 node1：192.168.174.10 node2：192.168.174.11 node3：192.168.174.12 node4：192.168.174.13 node5：192.168.174.14 其中，node1、node2、node3三台服务器安装RabbitMQ服务，n ...
分类：
其他好文 时间：
2020-10-06 20:40:24
阅读次数：
24
T1 problem: 给定一维空间内若干区间和一些点，要求选出其中某些区间(不能不选)使得存在一个点属于给定点集满足此点被每一个选出区间所包含 求选择的方案数 data range: \(N<=10^5\) solution: 对于每一个点考虑 将点按照位置从小到大排序 如果当前有A个区间包含此点 ...
分类：
其他好文 时间：
2020-10-06 19:56:16
阅读次数：
28
Celery+RabbitMQ实现订阅发布模式使用RabbitMQ的扇形交换机(fanoutexchange)实现订阅发布模式消息(Message)由Client发送，RabbitMQ接收到消息之后通过交换机转发到对应的队列上面。Worker会从队列中获取未被读取的数据处理。RabbitMQ消息模式的核心理念是：生产者没有直接发送任何消费到队列。实际上，生产者都不知道这个消费是发送给哪个队列的。相
分类：
其他好文 时间：
2020-10-05 22:08:39
阅读次数：
27
题意 问题转化成, 有 \(N\) 堆石子, 博弈双方每次可以选择不超过 \(M\) 堆, 每堆取不超过 \(X\) 个, 总的取石子数至少为一. 问胜利方. 题解 对于单堆来说是一个巴什博弈, \(SG\) 值为石子数模 \(X+1\). 我们回忆 \(M=1\) 时的 \(Nim\) 博弈, 它 ...
分类：
其他好文 时间：
2020-10-05 21:47:14
阅读次数：
26
MQ 的作用的什么 ： 异步解耦削峰 使用监听来控制队列有变化的时候，给你服务发送请求， 最后是一个监听对一个服务。 RabbitMQ 使用的协议 AMQP协议； Rabbit 添加方式有四种类型： 常用的三种类型： 1 direct Exchange 直连 路由键 routing key = 设置 ...
分类：
其他好文 时间：
2020-09-24 22:04:40
阅读次数：
44
