阻塞队列 如果我们想要在线程安全的场景下使用队列，只有两个选择，一个是上面讲过的 ConcurrentLinkedQueue，还有就是我们要将的阻塞队列。 从名字我们就可以判断出阻塞队列适用的场景，那就是生产者消费者模式。阻塞对垒的添加和删除操作在队列满或者空的时候会被阻塞。这就保证了线程安全。 阻 ...
分类：
编程语言 时间：
2020-01-12 21:50:31
阅读次数：
74
SpringBoot整合RabbitMQ 入门2020-01-12 创建生产者类,并且在yml配置文件中配置5要素连接MQ yml配置文件 spring: rabbitmq: host: xx.xx.xx.xx port: 5672 virtual-host: / username: 默认guest ...
分类：
编程语言 时间：
2020-01-12 09:28:07
阅读次数：
85
Celery Celery是一个异步任务框架,是一个独立运行的服务.(内置socket) 相当于一个生产者消费者模型的任务队列. 拥有高可用,异步,简易,等特点. celery是一个独立的socket 官网 Celery 官网：http://www.celeryproject.org/ Celery ...
分类：
其他好文 时间：
2020-01-11 00:25:52
阅读次数：
79
方式一：读取文件输出到Kafka 1.代码 import org.apache.flink.api.common.serialization.SimpleStringSchemaimport org.apache.flink.streaming.api.scala.StreamExecutionEn ...
分类：
其他好文 时间：
2020-01-09 19:18:07
阅读次数：
382
最近一段时间在做SLAM有关的东西，研究源码的时候碰到了一段和c++的进程同步有关的代码，主要是有一个线程会获取待处理的图像&接收处理后的图像（main），另一个线程（process）获取图像后进行处理然后输出，图片的输入和输出都是典型的生产者消费者问题，所以两个线程用mutex进行同步。稍微花了一... ...
分类：
编程语言 时间：
2020-01-08 00:31:56
阅读次数：
113
点击查看折叠代码块 / 普通消息生产者 / public class Producer { public static void main(String[] args) throws Exception { // 创建一个消息发送入口对象，主要用于消息发送，指定生产者组 DefaultMQProdu ...
分类：
其他好文 时间：
2020-01-06 14:55:32
阅读次数：
67
class MyResource { private volatile boolean FLAG = true; //默认开启，进行生产+消费 private AtomicInteger atomicInteger = new AtomicInteger(); BlockingQueue<Strin ...
分类：
编程语言 时间：
2020-01-06 00:36:19
阅读次数：
108
1. RabbitMQ 有哪些重要的组件？ ConnectionFactory（连接管理器）：应用程序与Rabbit之间建立连接的管理器，程序代码中使用。 Channel（信道）：消息推送使用的通道。 Exchange（交换器）：用于接受、分配消息。 Queue（队列）：用于存储生产者的消息。 Ro ...
分类：
其他好文 时间：
2020-01-05 19:05:19
阅读次数：
83
package communication; /* 使用两个线程1,2交替打印1-100 线程通信方法： 1.wait():一旦执行此方法，当前线程进入阻塞态，并释放锁 2.notify():会唤醒被wait的一个线程，如果有多个线程wait，则唤醒优先级高的 3.notifyAll():唤醒所有被 ...
分类：
编程语言 时间：
2020-01-05 18:36:13
阅读次数：
94
温馨提示：本文基于 Kafka 2.2.1 版本。本文主要是以源码的手段一步一步探究消息发送流程，如果对源码不感兴趣，可以直接跳到文末查看消息发送流程图与消息发送本地缓存存储结构。 从上文 "初识 Kafka Producer 生产者" ，可以通过 KafkaProducer 的 send 方法发送 ...
分类：
其他好文 时间：
2020-01-05 18:32:04
阅读次数：
107
