导入依赖 生产者provider 目录 接口IDoSomeService 实现类 IDoSomeServiceImpl 配置文件application.properties 测试类DubboProvider 消费者consumer 目录 接口类IDoSomeService DubboControll ...
分类：
编程语言 时间：
2019-12-14 15:45:49
阅读次数：
114
生产者 结构 导入依赖 <dependency> <groupId>com.101tec</groupId> <artifactId>zkclient</artifactId> <version>0.10</version> </dependency> <dependency> <groupId>c ...
分类：
编程语言 时间：
2019-12-14 15:31:42
阅读次数：
69
线程 1，生产者消费者模型 1. 什么是生产者与消费者模型 生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题，生产者和消费者之间不直接通讯，而通过阻塞队列来通讯，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力 在并发编程中使用生产者和消费者模式能够解决大多数并发问题，该模式 ...
分类：
编程语言 时间：
2019-12-13 13:46:51
阅读次数：
89
概念阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。应用阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生 ... ...
分类：
编程语言 时间：
2019-12-12 01:14:35
阅读次数：
93
课程回顾: 并行:在同一时间点上多个任务同时执行 并发:在同一时间段上多个任务同时执行 进程的三大基本状态: 就绪状态:所有进程需要的资源都获取到了,除了CPU 执行状态:获取到了所有资源包括CPU,进程处于运行状态 阻塞状态:程序停滞不在运行,放弃CPU,进程此时处于内存里 什么叫进程? 正在运行 ...
分类：
系统相关 时间：
2019-12-11 09:18:21
阅读次数：
107
1. 什么是阻塞队列？ 阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。 ...
分类：
其他好文 时间：
2019-12-10 18:38:55
阅读次数：
96
生产者 package com.java.se.producer; import java.util.concurrent.BlockingQueue; public class Producer implements Runnable{ private BlockingQueue<Integer> ...
分类：
其他好文 时间：
2019-12-10 00:35:54
阅读次数：
108
RocketMQ是我们常用的消息中间件，在运行单元测试时，我们可能不需要真正发送消息（除非是为了测试发送消息），也不想因为连结不上RocketMQ的Broker,NameServer而影响单元测试运行。 那我们该如何Mock RocketMQ消息生产者呢？ 请看例子： 1 2 3 4 5 6 7 8 ...
分类：
其他好文 时间：
2019-12-09 19:42:10
阅读次数：
100
[toc] Kafka生产者端 可靠性保证： producer向broker发送消息数据，需要有一定的可靠性，至少要保证数据： 1、不丢失 2、不重复 producer提供了一些参数，在编写producer是进行合理设置和编写，就可以保证数据的可靠性。 acks 参数配置 为保证producer发送 ...
分类：
编程语言 时间：
2019-12-07 23:16:20
阅读次数：
165
进程，互斥锁，生产者消费者，线程 一、僵尸进程与孤儿进程 代码演示 二、子进程回收的两种方式 代码演示 三、进程守护 演示 四、进程间数据是隔离的 演示 五、进程互斥锁 演示 六、队列 演示 七、IPC（进程间通信） 演示 八、生产者与消费者 演示 子线程守护 十、线程互斥锁 演示 ...
分类：
编程语言 时间：
2019-12-07 23:13:24
阅读次数：
144
