如果业务中，对于kafka发送消息异步消费的场景，在业务上需要实现在消费时实现顺序消费， 利用kafka在partition内消息有序的特点，消息消费时的有序性。 1、在发送消息时，通过指定partition hash 2、consumer 消费消息时，需要使用亲缘性线程池进行消费，才能实现消息的基 ...
分类：
其他好文 时间：
2020-01-04 14:13:35
阅读次数：
90
Description:
Field kafkaUtil in cn.arebirth.uesr.consumer.controller.TestUserController required a bean of type 'cn.arebirth.common.utils.KafkaUtil' ... ...
分类：
编程语言 时间：
2020-01-03 21:21:08
阅读次数：
66
1.原理图： 2.设计实现思路： 1.生产者（发送方）投递事务消息到Broker中，设置该消息为半消息 不可以被消费； 2.开始执行我们的本地事务，将本地事务执行的结果（回滚或者提交）发送给Broker； 3.Broker获取回滚或者提交，如果是回滚的情况则删除该消息、如果是提交的话，该消息就可以被 ...
分类：
其他好文 时间：
2020-01-03 10:39:00
阅读次数：
486
前提 最近创业公司的项目组基于业务需要，开发一套新的微服务，考虑到选用的组件必须是主流、社区活跃、生态完善以及方便迁移到云上等因素，引入了 全家桶。微服务开发里面，一个很重要的功能就是服务发现与注册，笔者花了点时间做了一个 、`SOFARpc Nacos`实现微服务发现注册与远程调用的示例。 依赖版 ...
分类：
其他好文 时间：
2020-01-02 18:51:18
阅读次数：
101
Windows 10 系统 - business editions 和 consumer editions 的区别 ...
一、简介 开启慢查询日志，可以让MySQL记录下查询超过指定时间的语句，通过定位分析性能的瓶颈，才能更好的优化数据库系统的性能。 二、参数说明 slow_query_log 慢查询开启状态slow_query_log_file 慢查询日志存放的位置（这个目录需要MySQL的运行帐号的可写权限，一般设 ...
分类：
数据库 时间：
2020-01-01 20:48:59
阅读次数：
100
实体类People，有个返回list的buildPeopleList方法，方便测试。 测试类GroupByTest，分别根据性别分组，统计各个性别人数，以及各个性别映射姓名。 ...
分类：
编程语言 时间：
2020-01-01 13:28:18
阅读次数：
252
题目描述 给一个链表，若其中包含环，请找出该链表的环的入口结点，否则，输出null。 思路 如果slow走了L的长度那么fast走了2L 假设从开始到入口点的长度是s，slow在环里走的长度是d 那么 l = s + d 假设环内slow没走的长度是m，fast走的长度是n*(m+d) + d + ...
分类：
编程语言 时间：
2019-12-31 23:14:44
阅读次数：
78
开启慢查询对性能有影响，有影响但不是非常大。当发现性能问题时，可以开启一定时间的慢查询，如3天或一周。 开启慢查询，修改配置文件： slow_query_log=1; long_query_time=2; 为了能作用在所有连接上，可以修改配置文件后，写个批处理（右键属性改为以管理员身份运行），加入到 ...
分类：
数据库 时间：
2019-12-30 23:07:11
阅读次数：
107
@Component @RabbitListener(queues="my_fanout") public class Consumer { @RabbitHandler public void process(String msg){ System.out.println(msg); } } 但是 ...
分类：
编程语言 时间：
2019-12-30 19:20:34
阅读次数：
90
