生产者客户端整体架构：​整个生产者客户端由两个线程协调运行，这两个线程分别为主线程和Sender线程（发送线程）。在主线程中由KafkaProducer创建消息，然后通过可能的拦截器、序列化器和分区器的作用之后缓存到消息累加器（RecordAccumulator，也称为消息收集器）中。Sender线程负责从RecordAccumulator中获取消息并将其发送到kafka中。​Rec...

情况描述今天在使用docker run -d -p 9091:8080 -v /home/xuhaixing/docker/tomcat/webapps/:/usr/local/tomcat/webapps/ --name managertomcat xuhaixing/mytomcat挂载路径后，进入容器root@08066d03a043:/usr/local/tomcat#...

以redisson为例RLock lock = redissonClient.getLock(key);lock.lock(timeoutSecond, TimeUnit.SECONDS);原则：1.自己加的锁自己释放，2.锁到期了业务没执行完还需续期1. 加锁时执行lua脚本"if (redis.call('exists', KEYS[1])...

当我们不需要从eureka等获取服务列表时，可以自己指定服务列表。ribbon:eureka:#禁用eureka ribbonenabled: falseeureka-service:ribbon:#自己定义服务列表listOfServers: localhost:8080,localhost:8081ribbon.eureka.enabled:...

在上一篇的基础上：在eureka server的pom文件中加下面依赖：<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-security</a...

1.创建一个docker用户组sudo groupadd docker2.添加当前用户到docker用户组sudo usermod -aG docker $USER3.重新登陆

1.修改 eureka，zuul,自己的微服务的pom打包方式packaging>warpackaging>引入依赖org.springframework.bootspring-boot-starter-tomcatprovided  设置打包名称为ROOT，最后打包出来都是ROOT.war,每个微服务部署到不同的tomcat容器中  

前言：   把springboot工程，放在docker容器中运行，有很多种方法，本博客用maven插件与Dockerfile构建。代码：    首先构架一个springboot工程pom.xml如下：docker-maven-plugin为构建docker所需的maven插件&lt;?xml version="1.0" encoding="UTF-8&quo

Express专门提供了路由功能用来封装请求创建一个路由，express.Router()var express = require('express')// 1. 创建一个路由容器var router = express.Router()router.get('/get', function(req, res) {res.send('请求了/get')})router...

springboot版本：2.0.1.RELEASEspringcloud版本：Finchley.RELEASE 日志：2018-07-15 10:50:10.516INFO 16952 --- [main] c.x.springcloud.EurekaClientApplication: Started EurekaClientAppl...