Lambda表达式(也称为闭包),它允许我们将函数当成参数传递给某个方法,或者把代码本身当作数据处理。很多语言(Groovy、Scala等)从设计之初就支持Lambda表达式。但是java中使用的是匿名内部类代替。最后借助强大的社区力量,找了一个折中的Lambda实现方案,可以实现简洁而紧凑的语言结构。1、匿名内部类到Lambda的演化?匿名内部类,即一个没有名字的,存在于一个类或方法内部的类。当
分类:
编程语言 时间:
2020-08-02 10:02:48
阅读次数:
78
查看消费组详情: ./bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group test-consumer-group 查看topic详情: ./bin/kafka-topics.sh --to ...
分类:
其他好文 时间:
2020-07-31 18:03:33
阅读次数:
83
#1.1 kafka启动命令nohup bin/kafka-server-start.sh config/server.properties & #1.2 kafka停止命令bin/kafka-server-stop.sh #1.3. kafka重启systemctl restart kafka # ...
分类:
其他好文 时间:
2020-07-30 14:45:42
阅读次数:
79
https://zhuanlan.zhihu.com/p/159017211 看着这算法凌乱的很,太复杂了!说实话,确实挺复杂,蛮罗嗦的,但是代数法可以得到如下表格: 假设4个queueConsumer有2个可以整除Consumer有3个不可整除Consumer有5个无法都分配queue[0]Con ...
分类:
其他好文 时间:
2020-07-29 10:19:02
阅读次数:
69
package com.jeesite.modules.jiQiao.web;import java.util.function.Consumer;public class DemoConsumerTest01 { public static void main(String[] args) { / ...
分类:
编程语言 时间:
2020-07-26 19:40:41
阅读次数:
85
RabbitMq保证消息可靠性之确认模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类:
其他好文 时间:
2020-07-26 01:04:06
阅读次数:
114
一、总体介绍 使用一个 Dept 部门模块做一个微服务通用案例 Consumer消费者(Client)通过 REST 调用 Provider 提供者(Server)提供的服务。 一个父工程中创建多个 Module 子模块:MicroServiceCloud父工程(Project)下初次带着三个子模块 ...
分类:
编程语言 时间:
2020-07-24 21:11:42
阅读次数:
72
入门级demo,并没有数据库之类的! 1、项目结构 一个empty project下有两个module: boot-user-service-provider(服务提供者) 和 boot-order-service-consumer(服务消费者) 至于怎么在一个空项目下创建多个module自己去百度 ...
分类:
编程语言 时间:
2020-07-24 16:39:04
阅读次数:
76
集成华为推送 这类推送一般官方文档都比较详细,如果想要更加详细的了解建议查看官方文档。 官方文档地址:https://developer.huawei.com/consumer/cn/service/hms/pushservice.html 华为推送服务在开发前需要些准备 1.注册认证成为开发者 2 ...
分类:
编程语言 时间:
2020-07-24 09:47:58
阅读次数:
252
package com.sun4cloud.sunx.question.config; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.producer.Producer ...
分类:
其他好文 时间:
2020-07-21 21:29:44
阅读次数:
71