原因如果使用的是#!/usr/local/bin/python3这种方式，就会出现“/usr/local/bin/python3^M: bad interpreter: 没有那个文件或目录” 错误：如果使用的是#!/usr/bin/env python3这种方式，就会出现“没有那个文件或目录3”错误：出错的原因就是代码的每一行最后都多了3^M，这是由于我在Windows上编写的代码，然后放到Lin

jstat 命令格式如下所示为jstat的命令格式jstat -<option> [-t] [-h<lines>] <vmid> [<interval> [<count>]]使用jps查看java进程也可以直接使用ps -ef | grep java查看java进程如下表示分析进程id为25677的gc情况，每隔1000ms打印一次记录，

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

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...