mysql.help_topic 利用help_topic表把以逗号分隔的字符串转换成行。 SELECT substring_index(substring_index( a.rn,',',b.help_topic_id + 1 ),',' ,- 1) AS rn FROM (select '1,2 ...
分类：
数据库 时间：
2021-01-20 11:44:32
阅读次数：
0
消息追踪 消息跟踪，排查问题。追踪消息的生产和消费 Firehose Firehose 的原理是将生产者投递给RabbitMQ 的消息，或者RabbitMQ 投递给消费者的消息按照指 定的格式发送到默认的交换器上。这个默认的交换器的名称为 amq.rabbitmq.trace ，它是一个 topic ...
分类：
其他好文 时间：
2021-01-19 12:22:49
阅读次数：
0
订单多任务处理 能够让生产者的横向扩展，支持多个服务器； 生产者集群架构，消费端集群架构； 同一个队列的话，消息是被瓜分掉的 设置均衡消费端： channel.BasicQos(0, 1, false); //预取数量设置为1个; 设置false nuget ： 1. 生产者 using Rabbi ...
分类：
其他好文 时间：
2021-01-19 12:11:54
阅读次数：
0
前言 Kafka 是一款分布式消息发布和订阅系统，具有高性能、高吞吐量的特点而被广泛应用与大数据传输场景。它是由 LinkedIn 公司开发，使用 Scala 语言编写，之后成为 Apache 基金会的一个顶级项目。kafka 提供了类似 JMS 的特性，但是在设计和实现上是完全不同的，而且他也不是 ...
分类：
编程语言 时间：
2021-01-19 11:48:43
阅读次数：
0
词频统计： 要求：统计Harry Potter.txt文件中出现最多单词前十位 内容样例： 代码及结果： @Test//词频统计 def WordCount(): Unit ={ val conf=new SparkConf().setMaster("local[6]").setAppName("w ...
分类：
其他好文 时间：
2021-01-18 11:17:13
阅读次数：
0
Given a string , determine if it is?valid. A string is?valid?if, starting with an empty string , you can?transform into after performing the following ...
分类：
其他好文 时间：
2021-01-18 11:15:29
阅读次数：
0
一般我们在用到这种消息中件的时候，肯定会考虑要怎样才能保证数据不丢失，在面试中也会问到相关的问题。但凡遇到这种问题，是指3个方面的数据不丢失，即：producer consumer 端数据不丢失 broker端数据不丢失下面我们分别从这三个方面来学习，kafka是如何保证数据不丢失的 一.produ ...
分类：
其他好文 时间：
2021-01-18 10:53:52
阅读次数：
0
生产者 KafkaExtendProducer.send("topic","key","value"); 消费者 @Slf4j @RequiredArgsConstructor @Component public class ConsumerThread implements Runnable { ...
分类：
其他好文 时间：
2021-01-15 11:46:10
阅读次数：
0
在这个网络里面，R1下面的子网使用192.168.0.0/16的网络地址（这里只用作实验，保留地址不能直接用于公网），已经使用了三个，其他的留待扩容后使用。而ISP为了减小路由表已经对R1的地址进行了汇总，路由表已经在图上提供了。此时网络已经可以使用了。 但是有一个问题，如果ISP收到一个目标地址为 ...
分类：
其他好文 时间：
2021-01-15 11:44:49
阅读次数：
0
#include <iostream> #include <stack> using namespace std; class GetMinStack{ public: void push(int x); void pop(); int top(); int getmin(); private: s ...
分类：
其他好文 时间：
2021-01-13 11:27:28
阅读次数：
0
