一、问题答案 是不可以的 而且后注册的会替换前注册的，MqConsumer2会替换MqConsumer，并且只结束tag-2的消息 二、为什么呢？ 我们从源码的角度来分析下 1.订阅消息的方法 public void subscribe(String topic, String subExpress ...
分类：
其他好文 时间：
2019-06-08 01:07:33
阅读次数：
2837
下载golang环境，地址：https://studygolang.com/dl，这里使用的是1.11.10版本。 下载golang IDE，这里使用Lite，下载地址：http://liteide.org/cn/。 在使用go的时候如果依赖导入github上的，比如下面样式 我们需要先执行get操 ...
分类：
其他好文 时间：
2019-06-06 13:49:40
阅读次数：
96
https://blog.csdn.net/pipinet123/article/details/60866901 源博客地址:http://blog.csdn.net/pipinet123 MQTT交流群:221405150在MQTT群里有很多群友经常会把MQTT、MQTT Broker、MQTT ...
分类：
其他好文 时间：
2019-05-30 10:30:33
阅读次数：
112
在上一篇文章讲解MQ消息可靠性投递和幂等性中有提到confirm机制的重要性，现在更相信的说明一下 一、Confirm机制 Confirm就是消息确认，当Producer发送消息，如果Broker收到消息，会回复一个应答，我们可以以此来确认消息是否成功送达，是保证 消息可靠性投递的核心保障 Prod ...
分类：
其他好文 时间：
2019-05-24 18:59:08
阅读次数：
106
1、如果配置了delete.topic.enable=true 通过命令删除：./kafka topics.sh zookeeper 127.0.0.1:2181 delete topic apply_test 通过zookeeper client 删除掉broker下的topic， rmr /br ...
分类：
其他好文 时间：
2019-05-24 12:46:47
阅读次数：
98
1. Rocketmq消费模型(实时性) 常见的数据同步方式有这几种： push：producer发送消息后，broker马上把消息投递给consumer。这种方式好在实时性比较高，但是会增加broker的负载；而且消费端能力不同，如果push推送过快，消费端会出现很多问题。 pull：produc ...
分类：
其他好文 时间：
2019-05-19 19:23:56
阅读次数：
218
一、并发性 并发性是oltp数据库最重要的特性，但并发涉及到资源的获取、共享与锁定。 mysql:mysql以表级锁为主，对资源锁定的粒度很大，如果一个session对一个表加锁时间过长，会让其他session无法更新此表中的数据。虽然InnoDB引擎的表可以用行级锁，但这个行级锁的机制依赖于表的索 ...
分类：
数据库 时间：
2019-05-18 00:34:20
阅读次数：
166
本节内容 Celery介绍和基本使用 在项目中如何使用celery 启用多个workers Celery 定时任务 与django结合 通过django配置celery periodic task 一、Celery介绍和基本使用 Celery 是一个 基于python开发的分布式异步消息任务队列，通 ...
分类：
其他好文 时间：
2019-05-16 20:30:43
阅读次数：
181
概览 - kafka解决的问题- 主题 - 分区 - 消息- 生产者- broker - broker集群- 消费者 - 消费者组群 - 生产者分区和消费者群组- 消息可靠性- 消息系统 - 队列和广播 - 消息保序- 存储系统- 流处理- 整合- 应用场景- api分类kafka解决的问题 生产者 ...
分类：
其他好文 时间：
2019-05-16 15:16:21
阅读次数：
152
