前言 在前面的文章中，我们学习了如何通过java实现将消息发送到钉钉、和将消息发送到微信群聊。 基于上述基础，我们今天来接入pinpoint的告警，发送到钉钉群。 实操前准备 开始之前，推荐阅读一下，官方的告警说明文档。 阅读官方文档后，我们实际的来操作一遍。 按照官方说明，首先需要创建对应的用户组 ...
分类：
微信 时间：
2020-01-16 18:44:49
阅读次数：
221
钩子的注册： DefaultMQProducerImpl#registerSendMessageHook注册钩子处理类，可注册多个。 public SendResult sendMessage( final String addr, final String brokerName, final Me ...
分类：
其他好文 时间：
2020-01-16 00:50:30
阅读次数：
93
kafka的相关操作脚本 1、创建Topic./kafka-topics.sh --zookeeper cc13-141:2182 --topic mytopic --replication-factor 1 --partitions 1 --create 2、Topic列表./kafka-topi ...
分类：
其他好文 时间：
2020-01-12 20:03:55
阅读次数：
73
多进程的几种方法 Lock：可以避免访问资源时的冲突 Pool：可以提供指定数量的进程 Queue：多进程安全的队列，实现多进程之间的数据传递 Pipe：实现管道模式下的消息发送与接收 Lock（加锁） #加锁 ''' 输出为 work_1 start work_2 start work_1 end ...
分类：
编程语言 时间：
2020-01-12 11:49:33
阅读次数：
100
1.消息发送机制 Kafka的ack机制。 当producer向leader发送数据时，可以通过request.required.acks参数来设置数据可靠性的级别： 1（默认）：这意味着producer在ISR中的leader已成功收到的数据并得到确认后发送下一条message。如果leader宕 ...
分类：
其他好文 时间：
2020-01-11 20:15:43
阅读次数：
92
温馨提示：本文基于 Kafka 2.2.1 版本。 上文 "《源码分析 Kafka 消息发送流程》" 已经详细介绍了 KafkaProducer send 方法的流程，该方法只是将消息追加到 KafKaProducer 的缓存中，并未真正的向 broker 发送消息，本文将来探讨 Kafka 的 S ...
分类：
编程语言 时间：
2020-01-08 21:24:40
阅读次数：
215
点击查看折叠代码块 / 普通消息生产者 / public class Producer { public static void main(String[] args) throws Exception { // 创建一个消息发送入口对象，主要用于消息发送，指定生产者组 DefaultMQProdu ...
分类：
其他好文 时间：
2020-01-06 14:55:32
阅读次数：
67
温馨提示：本文基于 Kafka 2.2.1 版本。本文主要是以源码的手段一步一步探究消息发送流程，如果对源码不感兴趣，可以直接跳到文末查看消息发送流程图与消息发送本地缓存存储结构。 从上文 "初识 Kafka Producer 生产者" ，可以通过 KafkaProducer 的 send 方法发送 ...
分类：
其他好文 时间：
2020-01-05 18:32:04
阅读次数：
107
问题思考 订单系统和积分系统、财务记账系统在不同的系统中,如果订单操作成功,积分系统或财务系统没有对应的记录,就会造成数据不一致的情况,在这种背景下就需要有一套方案解决不一致的情况. 方案图如下（龙果学院方案图）： 在这个案例中只列举两个系统之间的分布式事务,可以简单的理解为订单系统和记账系统 示例 ...
分类：
其他好文 时间：
2020-01-03 10:47:01
阅读次数：
123
一、简介： RabbitMq 是实现了高级消息队列协议（AMQP）的开源消息代理中间件。消息队列是一种应用程序对应用程序的通行方式，应用程序通过写消息，将消息传递于队列，由另一应用程序读取 完成通信。而作为中间件的 RabbitMq 无疑是目前最流行的消息队列之一。 AMQP，即Advanced M ...
分类：
其他好文 时间：
2019-12-26 21:39:09
阅读次数：
95
