Java.Thread类 process(进程)和Thread(线程) 程序：指令和数据的有效集合，本身没有任何运行含有，是一个静态的概念 进程：执行程序的一次执行过程，是一个动态的概念。是系统资源分配的单位 线程：通常一个进程可以包含多个线程（由调度器安排调度，不可人为干预）一个进程至少有一个线程 ...
分类：
编程语言 时间：
2021-03-30 13:39:18
阅读次数：
0
消息的分发策略最基础的就是推，拉机制，这有个最好的理解就是git -> pull 和 push 在这基础上制定了有5中消息的分发策略。（√ 支持，× 不支持） 1.发布订阅：生产者生产多少条消息，每个消费者就消费多少条消息（push） 2.轮询分发：消息数/消费者数 = 每个消费者消费的消息数 （除 ...
分类：
其他好文 时间：
2021-03-12 12:15:59
阅读次数：
0
Object中有两个涉及到了线程的方法： void wait()：让当前线程进入等待状态，直到被唤醒；（会释放锁） void notify()：唤醒当前正在等待的线程。（只会通知，不会释放锁） 因为Object是所有类的鼻祖，所以每一个对象都拥有wait()和notify()。 生产者和消费者模型 ...
分类：
其他好文 时间：
2021-02-24 13:12:42
阅读次数：
0
Exchanger的功能可以使2个线程之间传输数据,它比生产者消费者模式使用的wait/notify要更加方便,类Exchanger中的exchange()方法具有阻塞的特色,也就是此方法被调用后等待其他线程来取得数据，如果没有其他线程取得数据，则一直阻塞等待。Exchanger主要有两个方法 :e ...
分类：
编程语言 时间：
2021-02-22 12:34:21
阅读次数：
0
queue模块实现了多生产者,多消费者队列 queue模块的常用类和异常 queue.Queue(maxsize=0) 先进先出(FIFO)的队列, maxsize: 队列的大小(即队列的元素个数),默认0,队列大小无限;如果超过maxsize,队列会加锁,添加新元素是被堵塞,直到队列中的元素小于m ...
分类：
编程语言 时间：
2021-02-19 13:10:44
阅读次数：
0
线程池基本机制 线程池是一种池化资源，其主要解决重复创建线程带来的额外开销。线程池的设计使用了生产者-消费者模型。向线程池中提交一个计算任务，执行提交动作的线程是生产者，线程池中的线程作为消费者来执行具体的计算。 Executor和ExecutorService Java中Executor是线程池的 ...
分类：
编程语言 时间：
2021-02-03 10:58:10
阅读次数：
0
#kafka ##1.kafka基础架构 Kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。 消息生产者（发布）将消息发布到topic中，同时有多个消息消费者（订阅）消费该消息。和点对点方式不同，发布到topic的消息会被所有订阅者消费。 （1）Producer ： ...
分类：
其他好文 时间：
2021-01-30 12:13:24
阅读次数：
0
发布者确认 发布者确认 是RabbitMQ扩展，可以实现可靠的发布。在通道上启用发布者确认后，代理将异步确认客户端发布的消息，这意味着它们已在服务器端处理。 生产者： package com..confirm; import com..utils.RabbitConstant; import com ...
分类：
其他好文 时间：
2021-01-21 10:41:58
阅读次数：
0
这个 Kafka 的专题，我会从系统整体架构，设计到代码落地。和大家一起杠源码，学技巧，涨知识。希望大家持续关注一起见证成长！ 我相信：技术的道路，十年如一日！十年磨一剑！ 往期文章 Kafka 探险 - 架构简介 Kafka 探险 - 源码环境搭建 前言 我们说 Kafka 是一个消息队列，其实更 ...
分类：
其他好文 时间：
2021-01-20 12:07:05
阅读次数：
0
消息追踪 消息跟踪，排查问题。追踪消息的生产和消费 Firehose Firehose 的原理是将生产者投递给RabbitMQ 的消息，或者RabbitMQ 投递给消费者的消息按照指 定的格式发送到默认的交换器上。这个默认的交换器的名称为 amq.rabbitmq.trace ，它是一个 topic ...
分类：
其他好文 时间：
2021-01-19 12:22:49
阅读次数：
0
