前言 与生产者对应的是消费者，应用程序可以通过KafkaConsumer来订阅主题，并从订阅的主题中拉取消息。不过在使用KafkaConsumer消费消息之前需要先了解消费者和消费组的概念，否则无法理解如何使用KafkaConsumer。 <!--more--> Consumer 消费者（Consu ...
分类：
其他好文 时间：
2020-07-21 11:34:08
阅读次数：
71
什么是RabbitMQ简介（优点）基于ErLang语言开发有高可用高并发的优点，适合集群。开源、稳定、易用、跨平台、支持多种语言、文档齐全。有消息确认机制和持久化机制，可靠性高。概念生产者和消费者Producer：消息的生产者Consumer：消息的消费者Queue消息队列提供了FIFO的处理机制，具有缓存消息的能力。在RabbitMQ中，队列消息可以设置为持久化，临时或者自动删除。如果是持久化的
分类：
其他好文 时间：
2020-07-19 11:25:40
阅读次数：
75
方法引用就是通过类名或方法名引用已经存在的方法来简化lambda表达式。那么什么时候需要用方法引用呢？如果lamdba体中的内容已经有方法实现了，我们就可以使用方法引用。一、方法引用的三种语法格式1.对象::实例方法名lamdba写法：@Testvoidtest1(){Consumer<String>con=x->System.out.println(x);}方法引用写法：@Te
分类：
编程语言 时间：
2020-07-14 15:03:15
阅读次数：
74
内容： 1. kafka的核心概念 Topic：主题 Partition：分区 分区具体在服务器上面表现为其实就是一个目录 一个主题下面，有多个分区，这些分区会存储到不同的kafka的服务器上面 或者我们可以这样说：其实就是在不同的主机上面建了不同目录 Producer：生产者 Consumer：消 ...
分类：
其他好文 时间：
2020-07-13 23:09:51
阅读次数：
98
起因 偶然间看了一下Angular的服务的依赖注入和rxjs的观察者流的使用，觉得还有点意思，就想在React中实现一下类似的。 准备工作 一个空的React项目。 安装rxjs，npm install rxjs --save; 实现思路 首先是根据业务需求，将需要抽离的全局状态使用不同的服务类进行 ...
分类：
Web程序 时间：
2020-07-13 18:38:40
阅读次数：
102
https://www.eweek.com/security/mark-russinovich-on-the-future-of-security Windows IT people everywhere owe thanks to Dr. Mark Russinovich, now a techn ...
分类：
其他好文 时间：
2020-07-13 16:52:05
阅读次数：
92
高并发 什么是高并发？ 答： 高并发简单的来说就是在同一时刻不同用户访问同一资源的问题，专业一点的说法就是在同一时刻有多个线程访问了同一个数据资源。 解决方案 答： 也许我们可以用锁来解决并发的问题，但是锁无疑带来的是效率的低下，用户体验也极低。我们想要的是快速返回，但是后面那一堆的逻辑怎么办呢？我 ...
分类：
其他好文 时间：
2020-07-12 16:47:09
阅读次数：
46
Dubbo教程 一． Dubbo简介 Dubbox 是一个分布式服务框架，底层采用netty通信，服务之间通过rpc调用 节点角色说明 节点 角色说明 Provider 暴露服务的服务提供方 Consumer 调用远程服务的服务消费方 Registry 服务注册与发现的注册中心 Monitor 统计 ...
分类：
其他好文 时间：
2020-07-08 15:31:52
阅读次数：
55
一.简单实现 需求：根据 flume 监控 exec 文件的追加数据，写入 kafka 的 test-demo 分区,然后启用 kafka-consumer 消费 test-demo 分区数据。 需求分析 1）flume的配置文件 在hadoop102上创建flume的配置文件 # define a ...
分类：
Web程序 时间：
2020-07-07 23:22:58
阅读次数：
79
查看防火墙状态 firewall-cmd --state 开放端口 firewall-cmd --zone=public --add-port=2181/tcp --permanent firewall-cmd --zone=public --add-port=9092/tcp --permanen ...
分类：
其他好文 时间：
2020-07-07 17:40:16
阅读次数：
62
