一、比较低级的办法是用wait和notify来解决这个问题。 消费者生产者问题： 这个问题是一个多线程同步问题的经典案例，生产者负责生产对象，消费者负责将生成者产生的对象取出，两者不断重复此过程。这过程需要注意几个问题： 不论生产者和消费者有几个，必须保证： 1.生产者每次产出的对象必须不一样，产生 ...
分类：
编程语言 时间：
2019-10-27 11:09:14
阅读次数：
90
一：消息确认种类 RabbitMQ的消息确认有两种。 一种是消息发送确认。这种是用来确认生产者将消息发送给交换器，交换器传递给队列的过程中，消息是否成功投递。发送确认分为两步，一是确认是否到达交换器，二是确认是否到达队列。 第二种是消费接收确认。这种是确认消费者是否成功消费了队列中的消息。 具体建议 ...
分类：
其他好文 时间：
2019-10-27 01:13:10
阅读次数：
64
一：确认种类 RabbitMQ的消息确认有两种。 一种是消息发送确认。这种是用来确认生产者将消息发送给交换器，交换器传递给队列的过程中，消息是否成功投递。发送确认分为两步，一是确认是否到达交换器，二是确认是否到达队列。 第二种是消费接收确认。这种是确认消费者是否成功消费了队列中的消息。 具体建议参考 ...
分类：
其他好文 时间：
2019-10-26 22:47:09
阅读次数：
152
[toc] 网络编程 开发架构 B/S: browser/server C/S: client/server OSI七层模型 应用层 表示层 会话层 传输层: 建立端口到端口的通信, TCP/UDP协议 网络层: 引入IP地址来进行跨局域网通信, 因特网协议 数据链路层: 规定分组方式, 以太网协议 ...
分类：
编程语言 时间：
2019-10-25 20:20:48
阅读次数：
106
```python 1.理论 - 互斥锁的作用: 让并发变成串行, 牺牲了执行效率, 保证了数据安全。 - 队列: 必须遵循先进先出。 - IPC(进程间通信): 进程间数据是相互隔离的,若想实现进程间通信,可以利用队列. - 生产者与消费者: 生产者: 生产数据的 消费者: 使用数据的 解决供需不... ...
分类：
编程语言 时间：
2019-10-22 20:25:45
阅读次数：
113
一、创建Spring boot 工程 创建过程不再描述，创建后的工程结构如下： POM文件中要加入几个依赖： 启动SpringbootApplication.java，出现下图界面则说明工程创建好了： 二、创建kafka生产者类，并通过控制器调用 kafka生产者类 application.yml配 ...
分类：
编程语言 时间：
2019-10-22 18:21:46
阅读次数：
88
#线程数据安全处理--同步锁 #递归锁 #队列，线程间数据的安全 #生产者消费者模型 ...
分类：
编程语言 时间：
2019-10-21 10:02:25
阅读次数：
82
sem mutex1=1; sem mutex2=1; sem empty=1000; sem full=0; producer() { while(1) { 生产一个产品 p(empty); p(mutex2); 放入缓冲区 v(mutex2); v(full); } } consumer() {... ...
分类：
其他好文 时间：
2019-10-20 20:08:19
阅读次数：
80
为什么读RocketMQ 消息队列在互联网应用中使用较为广泛，学习她可以让我门更加了解使用技术的工作原理 透过学习她的源码，拓宽认知 RocketMQ经历了阿里双十一 有哪些名词 Producer 消息生产者，负责产生消息 Consumer 消息消费者，负责消费消息 Producer Group 一 ...
分类：
其他好文 时间：
2019-10-20 17:36:01
阅读次数：
88
1、消息中间件 1、通讯方式 1、点对点 2、发布订阅 2、JMS 1、jms JMS是java消息服务，JMS的客户端之间可以通过JMS服务进行异步的消息传输。 2、消费模型 1、点对点 1、模型： 生产者 消息队列 消费者 2、发布订阅 1、模型： 生产者 主题 消费者 3、ActiveMQ使用 ...
分类：
其他好文 时间：
2019-10-20 17:33:57
阅读次数：
88
