概念说明 通常一个消息队列需要掌握的知识点有Topic（主体）、Producer（生产者）、Consumer（消费者）、Queue（队列）、Delivery Semantics（消息传递范式） 蛋疼的是不同的消息队列关于这些名词叫法不一样，含义也不是很精确。所以阿里起了一个项目OpenMessagi ...
分类：
其他好文 时间：
2020-05-29 10:38:16
阅读次数：
55
官方文档：http://mybatis.org/spring-boot-starter/mybatis-spring-boot-autoconfigure/ Maven仓库地址：https://mvnrepository.com/artifact/org.mybatis.spring.boot/my ...
分类：
编程语言 时间：
2020-05-28 16:40:51
阅读次数：
67
原文链接：java8 中的常用函数式接口 函数式接口 表达式 拓展 备注 Predicate T → boolean DoublePredicate IntPredicate LongPredicate 谓词 Consumer T → void DoubleConsumer IntConsumer ...
分类：
编程语言 时间：
2020-05-28 16:11:09
阅读次数：
110
必要性：业务的增加，各公司的数据不在仅仅的功能实现方面，更多的是对数据的优化问题。 1.定位低效率sql 慢查询日志 : 通过慢查询日志定位那些执行效率较低的 SQL 语句，用--log-slow-queries[=?le_name]选项启 动时，mysqld 写一个包含所有执行时间超过 long_ ...
分类：
数据库 时间：
2020-05-27 15:47:34
阅读次数：
91
1,安装依赖库 composer require php-amqplib/php-amqplib 地址:https://github.com/php-amqplib/php-amqplib 2，mq生产者.php include(__DIR__ . '../../public/config.php' ...
分类：
Web程序 时间：
2020-05-27 15:23:48
阅读次数：
257
Kafka最初考虑的问题是，customer应该从brokes拉取消息还是brokers将消息推送到consumer，也就是pull还push。在这方面，Kafka遵循了一种大部分消息系统共同的传统的设计：producer将消息推送到broker，consumer从broker拉取消息。 一些消息系 ...
分类：
其他好文 时间：
2020-05-27 09:22:10
阅读次数：
405
Kafa consumer消费消息时，向broker发出fetch请求去消费特定分区的消息，consumer指定消息在日志中的偏移量（offset），就可以消费从这个位置开始的消息，customer拥有了offset的控制权，可以向后回滚去重新消费之前的消息，这是很有意义的 ...
分类：
其他好文 时间：
2020-05-26 21:58:05
阅读次数：
373
zookeeper 是一个分布式的协调组件，早期版本的kafka用zk做meta信息存储，consumer的消费状态，group的管理以及 offset的值。考虑到zk本身的一些因素以及整个架构较大概率存在单点问题，新版本中逐渐弱化了zookeeper的作用。新的consumer使用了kafka内部 ...
分类：
其他好文 时间：
2020-05-25 23:38:48
阅读次数：
296
Consumer之自动提交在上文中介绍了ProducerAPI的使用，现在我们已经知道如何将消息通过API发送到Kafka中了，那么现在的生产者/消费者模型就还差一位扮演消费者的角色了。因此，本文将介绍ConsumerAPI的使用，使用API从Kafka中消费消息，让应用成为一个消费者角色。还是老样子，首先我们得创建一个Consumer实例，并指定相关配置项，有了这个实例对象后我们才能进行其他的操
同样是逻辑上的概念，是Kafka实现单播和广播两种消息模型的手段。同一个topic的数据，会广播给不同的group；同一个group中的worker，只有一个worker能拿到这个数据。换句话说，对于同一个topic，每个group都可以拿到同样的所有数据，但是数据进入group后只能被其中的一个w ...
分类：
其他好文 时间：
2020-05-24 10:06:48
阅读次数：
77
