消息追踪 消息跟踪，排查问题。追踪消息的生产和消费 Firehose Firehose 的原理是将生产者投递给RabbitMQ 的消息，或者RabbitMQ 投递给消费者的消息按照指 定的格式发送到默认的交换器上。这个默认的交换器的名称为 amq.rabbitmq.trace ，它是一个 topic ...
分类：
其他好文 时间：
2021-01-19 12:22:49
阅读次数：
0
收集日志后，日志级别分类，error 级别发送运维邮件需单独处理，其他记录 直接交换机，工作方式类似于单播，Exchange会将消息发送完全匹配Routing_key的Queue；筛选消息通过key进行； 1. 生产者 using RabbitMQMsgProducer.MessageProduce ...
分类：
其他好文 时间：
2021-01-19 12:13:34
阅读次数：
0
（1）消费消息失败后，重新加入队列并优先级处理； （2）根据消息的内容筛选出优先级高的进行设置，并发送 1. 生产者 using RabbitMQMsgProducer.MessageProducer; using Microsoft.Extensions.Configuration; using ...
分类：
其他好文 时间：
2021-01-19 12:12:57
阅读次数：
0
订单多任务处理 能够让生产者的横向扩展，支持多个服务器； 生产者集群架构，消费端集群架构； 同一个队列的话，消息是被瓜分掉的 设置均衡消费端： channel.BasicQos(0, 1, false); //预取数量设置为1个; 设置false nuget ： 1. 生产者 using Rabbi ...
分类：
其他好文 时间：
2021-01-19 12:11:54
阅读次数：
0
深拷贝一般用JSON.parse(JSON.stringify(object))就可以解决了， 也知道这种方法的局限性： 会忽略 undefined 不能序列化函数 不能解决循环引用的对象 因为MessageChannel的postMessage传递的数据也是深拷贝的，这和web worker的po ...
分类：
其他好文 时间：
2021-01-19 12:10:47
阅读次数：
0
前言 Kafka 是一款分布式消息发布和订阅系统，具有高性能、高吞吐量的特点而被广泛应用与大数据传输场景。它是由 LinkedIn 公司开发，使用 Scala 语言编写，之后成为 Apache 基金会的一个顶级项目。kafka 提供了类似 JMS 的特性，但是在设计和实现上是完全不同的，而且他也不是 ...
分类：
编程语言 时间：
2021-01-19 11:48:43
阅读次数：
0
一般我们在用到这种消息中件的时候，肯定会考虑要怎样才能保证数据不丢失，在面试中也会问到相关的问题。但凡遇到这种问题，是指3个方面的数据不丢失，即：producer consumer 端数据不丢失 broker端数据不丢失下面我们分别从这三个方面来学习，kafka是如何保证数据不丢失的 一.produ ...
分类：
其他好文 时间：
2021-01-18 10:53:52
阅读次数：
0
今日所学： AS 按钮的三种方式 (20条消息) Android studio使用小技巧之 快速生成onClick()点击方法_kill_bugs的博客-CSDN博客 遇到的问题： 一开始在虚拟机上运行一直没反应 后来在自己的手机上调试，有反应 后来新建了一个虚拟机，就可以了 还不知道问题出在哪里 ...
分类：
移动开发 时间：
2021-01-16 12:03:32
阅读次数：
0
http post请求后，返回消息码为504 504错误代表网关超时 （Gateway timeout），是指服务器作为网关或代理，但是没有及时从上游服务器收到请求。 服务器（不一定是 Web 服务器）正在作为一个网关或代理来完成客户（如您的浏览器或我们的 CheckUpDown 机器人）访问所需网 ...
分类：
Web程序 时间：
2021-01-16 11:39:43
阅读次数：
0
今天在做p2p客户端的收发消息操作，由于传的消息是个结构体，前四个字节被定义为整型，用来判断是哪类报文，在收消息的时候就涉及吧char*转换为int 做法如下： auto recv_buf=std::make_unique<char[]>(1024);//分配1024字节的动态空间作为缓冲区 int ...
分类：
编程语言 时间：
2021-01-15 12:12:31
阅读次数：
0
