搜索结果
查询Tags标签： consumer，共有 108条记录-
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 人评论 次浏览 -
干了几天的万字 RocketMQ Consumer启动流程及消息的拉取源码分析(保姆级分析)
文章目录 源码版本官方提供的Consumer消费消息的demo代码客户端消息的拉取带注释的源码地址参考关于我源码版本 4.8.0官方提供的Consumer消费消息的demo代码DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("please_rename_unique_group_name_4");…
2021/11/26 1:10:22 人评论 次浏览 -
干了几天的万字 RocketMQ Consumer启动流程及消息的拉取源码分析(保姆级分析)
文章目录 源码版本官方提供的Consumer消费消息的demo代码客户端消息的拉取带注释的源码地址参考关于我源码版本 4.8.0官方提供的Consumer消费消息的demo代码DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("please_rename_unique_group_name_4");…
2021/11/26 1:10:22 人评论 次浏览 -
kafka、rabbitmq、redis区别，各自适合什么场景？
转载kafka、rabbitmq、redis区别，各自适合什么场景？ - Kris-Q - 博客园 在应用场景方面RabbitMQ RabbitMQ遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性要求比较高的消息传递上，适合企业级的消息发送订阅，也是比较受到大家欢迎的。kafka kafka是L…
2021/11/21 2:12:07 人评论 次浏览 -
kafka、rabbitmq、redis区别，各自适合什么场景？
转载kafka、rabbitmq、redis区别，各自适合什么场景？ - Kris-Q - 博客园 在应用场景方面RabbitMQ RabbitMQ遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性要求比较高的消息传递上，适合企业级的消息发送订阅，也是比较受到大家欢迎的。kafka kafka是L…
2021/11/21 2:12:07 人评论 次浏览 -
mediasoup源码剖析-数据路由
一. mediasoup重要类说明Worker：mediasoup 流媒体处理进程 Router：路由对象，类似于房间的功能，保存了流之间的订阅关系，它接收 Producer 的数据并转发给订阅该 Producer 的 Consumer Producer：音视频流生产者，一路音频就算一个单独的生产者，一路视频也算一个单独的…
2021/11/1 1:12:05 人评论 次浏览 -
mediasoup源码剖析-数据路由
一. mediasoup重要类说明Worker：mediasoup 流媒体处理进程 Router：路由对象，类似于房间的功能，保存了流之间的订阅关系，它接收 Producer 的数据并转发给订阅该 Producer 的 Consumer Producer：音视频流生产者，一路音频就算一个单独的生产者，一路视频也算一个单独的…
2021/11/1 1:12:05 人评论 次浏览 -
Kafka 笔记
一、什么是kafka？Kafka最初由Linkedin 公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper 协调的分布式日志系统，也可以作为MQ消息系统。Linkedin 公司在2010 年贡献给了Apache基金会并成为了顶级开源项目。简单一句话，是一款分布式消息发布和订阅系…
2021/10/28 23:40:27 人评论 次浏览 -
Kafka 笔记
一、什么是kafka？Kafka最初由Linkedin 公司开发，是一个分布式、分区的、多副本的、多订阅者，基于zookeeper 协调的分布式日志系统，也可以作为MQ消息系统。Linkedin 公司在2010 年贡献给了Apache基金会并成为了顶级开源项目。简单一句话，是一款分布式消息发布和订阅系…
2021/10/28 23:40:27 人评论 次浏览 -
kafka学习（三）kafka基础理论
一、消费模式的选择kafka常见的消费模式有两种：单播模式：一条消息只能被某一个消费者消费的模式。 多播模式：一条消息能被多个消费者组中的消费者消费的模式。PS：记录消费偏移量是以组为单位进行的，增删消费者不影响。【会在下面进行说明】 单播模式定义：一条消息只…
2021/10/28 23:10:04 人评论 次浏览 -
kafka学习（三）kafka基础理论
一、消费模式的选择kafka常见的消费模式有两种：单播模式：一条消息只能被某一个消费者消费的模式。 多播模式：一条消息能被多个消费者组中的消费者消费的模式。PS：记录消费偏移量是以组为单位进行的，增删消费者不影响。【会在下面进行说明】 单播模式定义：一条消息只…
2021/10/28 23:10:04 人评论 次浏览 -
kafka max.poll.interval.ms配置太短
max.poll.interval.ms这个应该是消费者每次去kafka拉取数据最大间隔，如果超过这个间隔，服务端会认为消费者已离线。触发rebalancedemo1 public ConsumerDemo(String topicName) {2 Properties props = new Properties();3 props.put("bootstra…
2021/10/27 6:11:39 人评论 次浏览 -
kafka max.poll.interval.ms配置太短
max.poll.interval.ms这个应该是消费者每次去kafka拉取数据最大间隔，如果超过这个间隔，服务端会认为消费者已离线。触发rebalancedemo1 public ConsumerDemo(String topicName) {2 Properties props = new Properties();3 props.put("bootstra…
2021/10/27 6:11:39 人评论 次浏览 -
RocketMQ
RocketMQ概述 RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点： 能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的订阅者水平扩展能力 实时的消息订阅机制 亿级消息堆积能力 RocketMQ包含的组件NameServer：单点，供Producer和Consumer获取Broker地址 …
2021/10/17 23:40:03 人评论 次浏览 -
RocketMQ
RocketMQ概述 RocketMQ 是一款分布式、队列模型的消息中间件，具有以下特点： 能够保证严格的消息顺序 提供丰富的消息拉取模式 高效的订阅者水平扩展能力 实时的消息订阅机制 亿级消息堆积能力 RocketMQ包含的组件NameServer：单点，供Producer和Consumer获取Broker地址 …
2021/10/17 23:40:03 人评论 次浏览
