1. 为什么你们公司选择RabbitMQ作为消息中间件 在消息队列选型时,我们调研了市场上比较常用ActiveMQ,RabbitMQ,RocketMQ,Kafka。 RabbitMQ相对成熟稳定,这是我们选择它最主要的原因。 社区比较活跃,有完善的资料可以参考。 Rabbitmq的吞吐量可以达到万级 ...
分类:
其他好文 时间:
2021-06-22 18:28:57
阅读次数:
0
路由模式介绍 路由模式下,在发布消息时指定不同的routeKey,交换机会根据不同的routeKey分发消息到不同的队列中 .net 5.0 代码实现: 生产者实现 using RabbitMQ.Client; using System; using System.Text; namespace R ...
分类:
其他好文 时间:
2021-06-22 18:25:12
阅读次数:
0
一般情况下,生产者发送消息,先到先得,一个消费者消费之后,该条消息便消失不会再被消费,抢完即止。 那能否生产者发送的消息每个消费者都能接收到,都能消费呢? Fanout交换机就可以实现。 代码实现: 生产者: public class FanoutExchange { public void Fan ...
分类:
其他好文 时间:
2021-06-19 18:57:59
阅读次数:
0
1.修改composer.json 2.执行命令:composer update mk-j/php_xlsxwriter": "^0.37 ...
分类:
其他好文 时间:
2021-06-18 19:49:21
阅读次数:
0
一、JVM 二、Java集合 三、Java多线程并发 四、Java基础 五、Spring原理 六、微服务 七、Netty与RPC 八、网络 九、日志 十、RabbitMQ 十一、MongoDB 十二、设计模式 十三、负载均衡 十四、数据 十五、Java算法 十六、数据结构 十七、Hadoop 十八、 ...
分类:
编程语言 时间:
2021-06-13 10:00:32
阅读次数:
0
记录下本人在win10环境下安装RabbitMQ的步骤 第一步:下载并安装erlang 原因:RabbitMQ服务端代码是使用并发式语言Erlang编写的,安装Rabbit MQ的前提是安装Erlang。 下载地址:http://www.erlang.org/downloads 官网现在速度太慢,建 ...
在消息RabbitMQ时,我们关心的一个问题是手动ack还是自动ack,如果是自动ack就怕出现丢消息的情况 Flink以RabbitMQ作为Source,是怎么保证消息唯一性的呢,是怎么保证ack的. 首先引入依赖包 <dependency> <groupId>org.apache.flink</ ...
分类:
其他好文 时间:
2021-06-11 19:15:45
阅读次数:
0
一、安装workman composer require workerman/workerman 二、创建 Timer 命令 php think make:command Timers 三、实现Timer <?php declare (strict_types = 1); namespace app ...
分类:
Web程序 时间:
2021-06-11 17:46:22
阅读次数:
0
docker run -di --name kaka-rabbit -e RABBITMQ_DEFAULT_USER=admin -e RABBITMQ_DEFAULT_PASS=admin -p 15672:15672 -p 5672:5672 -p 25672:25672 -p 61613:61 ...
分类:
其他好文 时间:
2021-06-11 17:46:06
阅读次数:
0
生产者: package com.gavin.mq.direct; import com.gavin.utils.RabbitMQUtils; import com.rabbitmq.client.Channel; import com.rabbitmq.client.Connection; imp ...
分类:
其他好文 时间:
2021-06-10 18:34:25
阅读次数:
0