https://kafka.apachecn.org/intro.html 一、kafka能做什么？ 构造实时流数据管道，它可以在系统或应用之间可靠地获取数据。 (相当于message queue) 构建实时流式应用程序，对这些流数据进行转换或者影响。 (就是流处理，通过kafka stream t ...
分类：
其他好文 时间：
2021-07-01 17:05:23
阅读次数：
0
Rabbitmq 消息系统允许软件, 应用相互连接和扩展, 这些应用可以相互链接起来组成一个更大的应用, 或者将用户设备和数据进行连接。消息系统通过将消息的发送和接收分离来实现应用程序的异步和解耦。 或许你正考虑进行数据投递，非阻塞操作或者推送通知。或许你想要实现发布/订阅, 异步处理, 或者工作队 ...
分类：
其他好文 时间：
2021-06-29 15:39:30
阅读次数：
0
direct(current time and current queue number, 25 queue number equals 1 minute) reverse(target time and current queue number, 25 queue number equals 1 ...
分类：
其他好文 时间：
2021-06-28 21:06:27
阅读次数：
0
主题交换机，这个交换机其实跟直连交换机流程差不多，但是它的特点就是在它的路由键和绑定键之间是有规则的。 简单地介绍下规则： * (星号) 用来表示一个单词 (必须出现的) # (井号) 用来表示任意数量（零个或多个）单词 通配的绑定键是跟队列进行绑定的,例： 队列Q1 绑定键为 .TT. 队列Q2绑 ...
分类：
其他好文 时间：
2021-06-25 17:23:14
阅读次数：
0
队列的应用场景： 数组模拟队列： package com.model.queue; import java.util.Scanner; /** * @Description:测试类 * @Author: 张紫韩 * @Crete 2021/6/24 20:39 * * 数组模拟队列，并验证 */ p ...
分类：
编程语言 时间：
2021-06-25 16:46:50
阅读次数：
0
参考：https://www.linuxprobe.com/install-rabbitmq-on-centos-7.html 问题1：打不开管理页面 http://Your_Server_IP:15672/,而且观察日志发现 rabbitmq程序一直在自动重启 首先防火墙已经关了，启动服务的报错信 ...
分类：
其他好文 时间：
2021-06-23 17:07:23
阅读次数：
0
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
一些定义 PL 树的路径长度，即树根到每个叶节点的距离之和。 WPL 树的带权路径长度，即树根到每个叶节点的距离与每个叶结点权值的乘积之和。 哈夫曼树，也叫 Huffman 树，就是 WPL 最短的一种最优多叉树。 \(\) 哈夫曼树的构造 对于哈夫曼树的构造，我们以二叉哈夫曼树为例： 我们每次选择 ...
分类：
其他好文 时间：
2021-06-19 19:09:18
阅读次数：
0
一般情况下，生产者发送消息，先到先得，一个消费者消费之后，该条消息便消失不会再被消费，抢完即止。 那能否生产者发送的消息每个消费者都能接收到，都能消费呢？ Fanout交换机就可以实现。 代码实现： 生产者： public class FanoutExchange { public void Fan ...
分类：
其他好文 时间：
2021-06-19 18:57:59
阅读次数：
0
