Docker主机 IP地址172.19.184.202 rabbit1 rabbit1172.19.184.201 rabbit2 rabbit2第一步：获取RabbitMQ镜像docker pull rabbitmq:management第二步：启动MQrabbit1：172.19.184.202rabbitmq集群建立需要解析主机名，因此需要一台内网DNS，...

最近有个需求就是按照uuid进行分组排序，虽然最初的list是按照时间排序的，但是分组后一直数据都是错乱的，后来查了资料可以看到groupingBy有三个参数，第一个参数就是key的Function了，第二个参数是一个map工厂，也就是最终结果的容器，一般默认的是采用的HashMap::new，最后一个参数很重要是一个downstream，类型是Collector，也是一个收集器，那就是说，这三个

第一步：进入docker容器docker exec -it myrabbit1 bash第二步：查看当前用户列表rabbitmqctllist_users第三步：修改密码rabbitmqctlchange_passwordUsername'Newpassword'...

在《阿里巴巴java开发手册》中指出了线程资源必须通过线程池提供，不允许在应用中自行显示的创建线程，这样一方面是线程的创建更加规范，可以合理控制开辟线程的数量；另一方面线程的细节管理交给线程池处理，优化了资源的开销。而线程池不允许使用Executors去创建，而要通过ThreadPoolExecutor方式，这一方面是由于jdk中Executor框架虽然提供了如newFixedThreadPool

在实际的kafka开发中，我们会发现，无论是生产者还是消费者，都需要构建一个Properties对象，里面设置了很多参数。对于很多初学者来说，会看不懂这些参数分别代表什么含义。在本篇文章我们就来详细地了解一下这些参数的作用，并探讨下如何使用合理的配置去优化提高生产/消费效率1.kafka生产者参数Properties props = new Properties();props.pu...

在spring应用中如果需要订阅kafka消息，通常情况下我们不会直接使用kafka-client, 而是使用更方便的一层封装spring-kafka。不过，它可不是简单的封装了kafka-client, 这里面有很多需要注意的问题，比如下面这个参数：spring.kafka.listener.concurrency=31它并不像参数名那样简单，背后挺复杂的。如果你用jstack把线程du...

第一步：安装docker-compose1.从github上下载docker-compose二进制文件安装下载最新版的docker-compose文件$ sudo curl -L https://github.com/docker/compose/releases/download/1.16.1/docker-compose-`uname -s`-`uname -m` -o /usr...

一. 常用消息队列工具  目前常用的消息队列大概有三种类型,RabbitMQ等AMQP系列, Kafka, Redis等kev value系列,它们的使用场景分别是：  1.RabbitMQ： 相对重量级高并发的情况，比如数据的异步处理 任务的串行执行等.  2.Kafka： 基于Pull的模式来处理,具体很高的吞吐量,一般用来进行 日志的存储和收集.  3.Redis: 轻...

otter是阿里巴巴开源数据同步解决方案，官网：https://github.com/alibaba/otterotter node依赖于zookeeper进行分布式调度，需要安装一个zookeeper节点或者集群.zookeeper的安装可以参考我之前写的另外一篇博客docker-compose 部署zk和kafkaotter环境搭建步骤：docker安装参考官网，不过我尝试过，do...

Spring boot集成kafka时候，能够正常发送消息，但是接受消息时，报错org.apache.kafka.common.errors.SerializationException，提示序列化错误(自定义的消息对象不在kafka信任的包路径下)org.apache.kafka.common.errors.SerializationException: Error deserializ...