搜索结果
查询Tags标签： consumer，共有 108条记录-
Kafka学习之一深度解析
背景介绍 Kafka简介Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下：以时间复杂度为O(1)的方式提供消息持久化能力，即使对TB级以上数据也能保证常数时间的访问性能 高吞吐率。即使在非常廉价的商用机器上也能做到单机支持每秒100K条消息的传输 支持Kaf…
2021/12/23 23:09:46 人评论 次浏览 -
Kafka学习之一深度解析
背景介绍 Kafka简介Kafka是一种分布式的，基于发布/订阅的消息系统。主要设计目标如下：以时间复杂度为O(1)的方式提供消息持久化能力，即使对TB级以上数据也能保证常数时间的访问性能 高吞吐率。即使在非常廉价的商用机器上也能做到单机支持每秒100K条消息的传输 支持Kaf…
2021/12/23 23:09:46 人评论 次浏览 -
Jaeger的客户端采样配置(Java版)
欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等； 关于采样（Sampling）采样很好理解：使用Jaeger时，未必需要将所有请求都上报到Jaeger，有时候只要抽取其中一部分观察即可，…
2021/12/21 9:19:37 人评论 次浏览 -
Jaeger的客户端采样配置(Java版)
欢迎访问我的GitHub https://github.com/zq2599/blog_demos 内容：所有原创文章分类汇总及配套源码，涉及Java、Docker、Kubernetes、DevOPS等； 关于采样（Sampling）采样很好理解：使用Jaeger时，未必需要将所有请求都上报到Jaeger，有时候只要抽取其中一部分观察即可，…
2021/12/21 9:19:37 人评论 次浏览 -
PHP + RabbitMQ + TP6实现，记录操作全过程
目录 前言 composer安装扩展 遇到的问题 代码展示 1.api接口，进行消息发布 2.生产者类库 3.消费者类库 4.目录结构 5.PHP中 register_shutdown_function 函数的基础介绍与用法详解 windows上运行消费者类库 1.项目根目录下执行 2.执行后代码展示 3.修改下config/console…
2021/12/18 1:19:39 人评论 次浏览 -
PHP + RabbitMQ + TP6实现，记录操作全过程
目录 前言 composer安装扩展 遇到的问题 代码展示 1.api接口，进行消息发布 2.生产者类库 3.消费者类库 4.目录结构 5.PHP中 register_shutdown_function 函数的基础介绍与用法详解 windows上运行消费者类库 1.项目根目录下执行 2.执行后代码展示 3.修改下config/console…
2021/12/18 1:19:39 人评论 次浏览 -
Spring Cloud Stream RocketMQ Binder 源码分析
Spring Cloud Stream 用来做什么Spring Cloud Stream provides unified abstractions of message middleware configurations, and puts forward concepts such as publish-subscribe, consumer groups and partition.Spring Cloud Stream 提供了统一的抽象消息中间件配置…
2021/12/7 9:46:51 人评论 次浏览 -
Spring Cloud Stream RocketMQ Binder 源码分析
Spring Cloud Stream 用来做什么Spring Cloud Stream provides unified abstractions of message middleware configurations, and puts forward concepts such as publish-subscribe, consumer groups and partition.Spring Cloud Stream 提供了统一的抽象消息中间件配置…
2021/12/7 9:46:51 人评论 次浏览 -
kafka在python中的使用及结束kafka消费者
先说下问题： 正常使用kafka消费者，接收消息时，会出现消息循环无法结束问题，增加参数 consumer_timeout_ms:超时时间（毫秒），超过指定时间没有获取到消息关闭kafka。（例子如下） consumer.py文件： from kafka import KafkaProducer, KafkaConsumer import timeclas…
2021/12/6 17:17:14 人评论 次浏览 -
kafka在python中的使用及结束kafka消费者
先说下问题： 正常使用kafka消费者，接收消息时，会出现消息循环无法结束问题，增加参数 consumer_timeout_ms:超时时间（毫秒），超过指定时间没有获取到消息关闭kafka。（例子如下） consumer.py文件： from kafka import KafkaProducer, KafkaConsumer import timeclas…
2021/12/6 17:17:14 人评论 次浏览 -
Dubbo源码解析-Consumer发送请求全过程
前言： 之前的文章已经从调用结构方面从前到后整个梳理了一下全过程。 本篇就从实战调用角度来分析下整个过程，之前是抽象，现在就是实战。1.示例代码 代码的话跟之前是一样的，笔者在这里再贴一下 1.1 provider public class ProviderApplication {public static void m…
2021/11/30 12:36:31 人评论 次浏览 -
Dubbo源码解析-Consumer发送请求全过程
前言： 之前的文章已经从调用结构方面从前到后整个梳理了一下全过程。 本篇就从实战调用角度来分析下整个过程，之前是抽象，现在就是实战。1.示例代码 代码的话跟之前是一样的，笔者在这里再贴一下 1.1 provider public class ProviderApplication {public static void m…
2021/11/30 12:36:31 人评论 次浏览 -
RocketMQ高阶业务问题及解决方案
RocketMq全链路消息零丢失方案 发送消息到mq零丢失: 事务消息Broker 存储消息零丢失：同步刷盘+主从机制Consumer 消费消息零丢失：手动提交offset + 自动故障转移 Broker消息零丢失方案：同步刷盘 + Raft协议主从同步 Broker 是负责存储消息的，怎么保证消息发送到Broker…
2021/11/29 23:36:25 人评论 次浏览 -
RocketMQ高阶业务问题及解决方案
RocketMq全链路消息零丢失方案 发送消息到mq零丢失: 事务消息Broker 存储消息零丢失：同步刷盘+主从机制Consumer 消费消息零丢失：手动提交offset + 自动故障转移 Broker消息零丢失方案：同步刷盘 + Raft协议主从同步 Broker 是负责存储消息的，怎么保证消息发送到Broker…
2021/11/29 23:36:25 人评论 次浏览 -
linux监控脚本状态失败后拉起
while true # 无限循环 flag=`ps -aux |grep "consumer.py" |grep -v "grep" |wc -l` doif [[ $flag -eq 0 ]] # 判断进程数如果等于0，则启动脚本then`python3 -u consumer.py >> radius.log 2>&1 &` # 启动脚本echo `date` …
2021/11/28 7:16:11 人评论 次浏览
