因为ArrayBlockingQueue是一个阻塞的有界队列,可以直接使用它. ...
分类：
编程语言 时间：
2018-09-30 14:52:58
阅读次数：
188
public class Test { public static void main(String[] args) throws InterruptedException { List queue = new ArrayList(); new Thread(new PThread(queue)).... ...
分类：
编程语言 时间：
2018-09-30 12:46:20
阅读次数：
156
Java生产者与消费者模型是经典Java线程同步模型，涉及使用同步锁控制生产者线程和消费者线程同步运行问题。同步对象是仓库资源，生产者线程生产向仓库中生产商品，消费者线程从仓库中消费商品，当生产者线程生产的商品达到仓库的90%时，生产者线程停止生产并通知消费者线程开始消费，当消费者线程消耗到仓库的1 ...
分类：
编程语言 时间：
2018-09-29 16:47:36
阅读次数：
213
消费者 由于消费者那里，@Payload是接受的消息体，使用了@Header注解，需要请求头，生产者这边就要设置，如下代码： 这是RabbitTemplate中的converAndSend（exchang,routingKey,消息体,消息头）方法。 ...
分类：
其他好文 时间：
2018-09-29 16:02:43
阅读次数：
929
本文来自网易云社区 作者：田宏增 Kafka的高可靠性的保障来源于其健壮的副本（replication）策略。通过调节其副本相关参数，可以使得Kafka在性能和可靠性之间运转的游刃有余。Kafka从0.8.x版本开始提供partition级别的复制,replication的数量可以在$KAFKA_H ...
分类：
其他好文 时间：
2018-09-28 12:49:59
阅读次数：
124
进程 使用 导入类库 创建进程 Process参数：group=None,target=None, name=None, args=(), kwargs={}) 全局变量 进程间全局变量不共享，因为进程是复制出来的 线程 使用 导入类库 创建线程 Thread参数：group=None,target ...
分类：
编程语言 时间：
2018-09-27 22:01:46
阅读次数：
155
什么是MQ？ MQ全称为Message Queue, 消息队列（MQ）是一种应用程序对应用程序的通信方法。MQ是消费-生产者模型的一个典型的代表，一端往消息队列中不断写入消息，而另一端则可以读取队列中的消息。 RabbitMQ是MQ的一种。下面详细介绍一下RabbitMQ的基本概念。 1、队列、生产 ...
分类：
其他好文 时间：
2018-09-27 11:14:56
阅读次数：
114
第1节 MySQL基础 一，说明 关系型数据库通过外键关联来建立表与表之间的关系， 非关系型数据库通常指数据以对象的形式存储在数据库中，而对象之间的关系通过每个对象自身的属性来决定 关系型数据库通过外键关联来建立表与表之间的关系， 非关系型数据库通常指数据以对象的形式存储在数据库中，而对象之间的关系 ...
分类：
数据库 时间：
2018-09-26 23:57:52
阅读次数：
383
事务&生产者确认 一般情况下，生产者将消息发送后，继续进行别的业务逻辑处理。消息从生产者发送后，可能由于网络原因丢失，也可能因为RabbitMQ服务端奔溃未被处理...总之,对于 消息是否安全到达服务器，生产者一无所知。在一些场景下，这也许是可行的，毕竟丢失消息的几率较小，丢失几条消息也并不会产生严 ...
分类：
其他好文 时间：
2018-09-24 13:40:12
阅读次数：
131
一、基本概念 1. AMQP AMQP，即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议。支持不同语言和不同的产品 2. 生产者 消息的创建者，发送到AMQP的消息中间件 3. 消费者 连接到AMQP的消息中间件，订阅到队列上，进 ...
分类：
其他好文 时间：
2018-09-23 22:38:11
阅读次数：
202
