路漫漫其修远兮
吾将上下而求索

service

Kafka学习:topic、consumer group状态命令

最近工作中遇到需要使用kafka的场景,测试消费程序启动后,要莫名的过几十秒乃至几分钟才能成功获取到到topic的partition和offset,而后开始消费数据,于是学习了一下查看kafka broker里topic和consumer ...

算法学习:bfs+dfs

– 概念 深度优先搜索算法(Depth-First-Search),是搜索算法的一种。它沿着树的深度遍历树的节点,尽可能深的搜索树的分 支。堆栈实现,递归实现 广度优先搜索算法(Breadth-First-Search),是一种...

算法学习:快排

目录 快速排序的介绍 快速排序的Python实现 快速排序的介绍 快速排序(quick sort)的采用了分治的策略。 分治策略指的是:将原问题分解为若干个规模更小但结构与原问题相似的子问题。递归地解这些子问题,然后将这些子问题的解组合为原...

rabbitmq学习(5):Topic

相比fanout类型,基于direct类型的交换器实现的日志记录系统,可以让我们有选择的接收日志。而在其他的一些场景下,direct类型交换器仍然不能够满足人们日益增长的需求。比如:不仅需要对日志的级别进行过滤,还要对日志源进行过滤。 1....

rabbitmq学习(4):Routing

与fanout类型的交换器绑定了的队列,会收到所有经过该交换器的消息,即fanout类型的交换器会转发所有消息到与之绑定的队列中。那么,如果消费者应用程序只想接收经过交换器的一部分消息,该怎么办呢? 1.再谈绑定 前面的章节中,我们已经介绍...

rabbitmq学习(3):Publish/Subscribe

前一篇文章学习了工作队列,细心的你或许会发现:生产者生产的每一条特定的消息要么被消费者C1消费,要么被消费者C2消费。也就是说,一条消息只能被一个消费者消费。那么,多个消费者如何消费同一条消息呢? 1.fanout类型交换器 我们将“向多个...

rabbitmq学习(2):Work Queues

前面介绍了简单的RabbitMQ示例:一个生产者、一个消费者。然而,面对复杂耗时的任务时,为了提高工作效率,往往会使用多个消费者进行消费。此时的工作队列(Work Queue)需要将消息分发给多个消费者。 为了模拟出复杂、耗时的任务,我们假...

rabbitmq学习(1):Hello World

在熟悉了AMQP的相关概念之后,再学习RabbitMQ就比较容易了。毕竟RabbitMQ是对AMQP的实现,并且RabbitMQ提供了包括c/c++, python, java等众多语言可供开发者选择使用。 1.RabbitMQ Rabbi...

rabbitmq学习:消息队列面试题

消息队列连环炮 项目里怎么样使用 MQ 的? 为什么要使用消息队列? 消息队列有什么优点和缺点? kafka,activemq,rabbitmq,rocketmq 都有什么去呗? 如何保证消息队列高可用? 如何保证消息不被重复消费? 如何保...

confluence安装

系统环境:当前服务器centos7.4(建议内存至少2G以上),本地使用windows7主机 本地先下载confluence破解包 confluence破解工具.zip 本地安装java 官网下载 注意:破解包需要java来运行,我这里提供...