微信公众号：[中间件兴趣圈]作者简介：《RocketMQ技术内幕》作者方案背景背景：基于Dubbo服务的治理，是否可以支持业务级别的灰度发布、是否基于业务参数的路由转发。例如以GIS为例，当发布一个新版本时，是否可以以按照解析地址或合作伙伴来区分，版本发布之初，只希望地址为：广东省的解析请求发送到新版本，而其他的地址请求还是使用旧版；或者根据合作伙伴例如UCP(优享寄)的请求转发到新版本服务器，其
分类：
其他好文 时间：
2020-12-08 12:47:20
阅读次数：
5
Kafka里面的信息是如何被消费的？摄影：产品经理跟着产品经理去苏州吃面作为一个爬虫工程师，Kafka对你而言就是一个消息队列，你只需要掌握如何向里面写入数据，以及如何读取数据就可以了。请谨记：使用Kafka很容易，但对Kafka集群进行搭建、维护与调优很麻烦。Kafka集群需要有专人来维护，不要以为你能轻易胜任这个工作。”本文，以及接下来的几篇针对Kafka的文章，我们面向的对象都是爬虫工程师或
分类：
其他好文 时间：
2020-12-08 12:03:19
阅读次数：
3
一日一技：一个生成器如何当两个用？摄影：产品经理买单：kingname我们知道，Python里面的生成器只能被消费一次，例如下面的代码：defname_generator():fornamein[‘产品经理‘,‘kingname‘]:yieldnamedefsay_hello(g):print(‘hello函数开始运行‘)fornameing:print(‘hello‘,name)print(‘h
分类：
其他好文 时间：
2020-12-08 11:58:59
阅读次数：
3
消息组接到某项目组反馈，topic在扩容后出现部分队列无法被消费者，导致消息积压，影响线上业务？考虑到该问题是发送在真实的线上环境，为了避免泄密，本文先在的虚拟机中来重现问题。1、案情回顾1.1集群现状集群信息如下：例如业务主体名topic_dw_test_by_order_01的路由信息如图所示：当前的消费者信息：broker的配置信息如下：brokerClusterName=DefaultCl
分类：
其他好文 时间：
2020-12-07 12:44:57
阅读次数：
13
主从模式环境可以保障消息的即时性与可靠性投递一条消息后，关闭主节点从节点继续可以提供消费者数据进行消费,但是不能接收消息主节点上线后进行消费进度offset同步准备两台机器，一主一从：机器IPhostname角色192.168.243.169rocketmq01master192.168.243.170rocketmq02slave我这里事先在两台机器上安装好了RocketMQ，关于RocketM
分类：
其他好文 时间：
2020-12-05 10:54:50
阅读次数：
10
Apache Kafka由Scala和Java编写，基于生产者和消费者模型作为开源的分布式发布订阅消息系统。它提供了类似于JMS的特性，但设计上又有很大区别，它不是JMS规范的实现，如Kafka允许多个消费者主动拉取数据，而在JMS中只有点对点模式消费者才会主动拉取数据 ...
分类：
其他好文 时间：
2020-12-04 11:04:22
阅读次数：
7
将 auto.commit.offset 设为 false，然后在处理一批消息后 commitSync() 或者 异步提交 commitAsync() 即： ConsumerRecords<> records = consumer.poll(); for (ConsumerRecord<> reco ...
分类：
其他好文 时间：
2020-12-03 12:16:37
阅读次数：
6
? 这篇文章主要是讲述dubbo的消费者初始化发生的事情，比如：怎么注入和注入什么对象到带有@DubboReference和@Reference注解的成员变量里，怎么去建立dubbo的连接，怎么获取注册中心里提供者的地址等等 消费端的入口-DubboAutoConfiguration ? 因为根据s ...
分类：
其他好文 时间：
2020-11-27 11:13:36
阅读次数：
7
当代，我们的生活节奏不断加快，逐渐进入了快消费时代，在线教育软件顺应时代潮流而走进大家的视野中，与传统教育方式相比，在线教育提高了我们的学习效率，让我们在更短的时间内学到各种知识，提高我们的能力。所以深受用户喜爱，在线教育软件开发商看到了发展的契机，纷纷顺势而上。在线教育软件开发开发能够使教育机构大大减少推广费用，免费在线捕捉到新商机，全自动检索潜在的学员，轻轻松松制定全部教学环节，并按照地域，课
分类：
其他好文 时间：
2020-11-26 14:22:27
阅读次数：
2
给大家安利一款 ServiceStack.Redis 的 ASP.NET Core 扩展库，它是基于 ServiceStack.Redis.Core 开发的。 简单易用，开源免费，使用ASP.NET Core自身提供的DI容器来实现针对服务的注册和消费。直接在程序启动时注册到服务中即可完成全部配置， ...
分类：
Web程序 时间：
2020-11-26 14:08:07
阅读次数：
11
