elasticsearch 用JAVA 查询数据太多，一次性返回数据有限制， 用车架号分组返回数据的时候，一直误认为.setFrom(0).setSize(100)就是查询返回的数据，这样的语句在单查询的时候没有问题，但是在addAggregation 中， 或者分组查询等情况下，根本没有效果，必须在addAggregation 返回数据前加上要取多少条记录如  addAggregatio...

一 首生是kafka -stream 版本号问题，然后是springboot1.5.6兼容问题，发现springboot2.0不支持kafka -stream1.0.2包第一个是窗口聚合的初始值，第二个是进行聚合的聚合器，第三个就是窗口时间，第四个是类似于序列化的东西KTable aggregate = groupedStream.aggregate(initializer, ag...

两个类注入进去， 不会循环依赖， 就是利用scope分数来决定取出哪个服务消息，放回奖品池// 加入30分钟 过期时间回收资源//delayQueueService.orderDelay(value,1800000);//(180000 三分钟)delayQueueMachineManager.addJobId(awardVO.getUserParticipateId(),award.getId(

java 生成xml

<!-- 安装ifconfig --> yum install net-tools <!-- 安装vim --> yum install yum <!-- 准备基础编译环境 --> yum install gcc glibc-devel make ncurses-devel openssl-devel xmlto 

多任务情况下，quartz更容易管理，可以实现动态配置 执行时间表达式： 表达式示例： 微服务启动时 必须加上@EnableScheduling下面是单纯schedule 用法，简单@Scheduled(cron="0/5 * * * * ?")public void job(){System.out.println("每五秒执行一次");...

今天遇到问题， 项目上传了一个GEO文件，但是在容器里运行的时候，找不到路径，因为容器里没有项目文件路径，只有一个JAR包， 这样的话，就要在容器里创建一个工作目录，然后打包容器的时候，把文件copy或者 add进容器里，代码如下1 第一步，docker 文件createDockerFile.sh 在服务端直接用命令 。 shcreateDockerFile.sh ,拉代码和打...

当服务消费端去调用服务提供者的服务的时候，已经封装了一个模板类，叫做RestTemplate，当时只使用了RestTemplate中最简单的一个功能getForEntity发起了一个get请求去调用服务端的数据，同时，我们还通过配置@LoadBalanced注解开启客户端负载均衡，RestTemplate的功能不可谓不强大，如feign 和Rabbon+RestTemplate等两种方式负载均衡.

redis 配置 需要注意的地方是多服务器的时候，格式不一样@Configuration@ConditionalOnClass({JedisCluster.class})public class RedisConfig {@Value("${spring.redis.cluster.nodes}")private String clusterNod...

三台服务器准备工作安装java环境搭建zookeeper集群搭建kafka集群服务器配置主机名IP地址硬件配置kafka-1192.168.1.16224CPU、46G内存、600G存储kafka-2192.168.1.16624CPU、64G内存、600G存储kafka-3192.168....