RabbitMq-消息持久化 问题：怎样保证消息不因生产者gg而丢失我们知道了如何在消费者的角度保证消息不丢失，但如果生产者gg了呢，消息同样会丢失，生产者gg后会默认丢弃所有的消息，除非告诉它某些消息是不能丢失的。 解决策略：消息持久化使用消息持久化，将消息保存到磁盘上，而不是内存中，即使生产者g ...
分类：
其他好文 时间：
2018-11-28 18:56:02
阅读次数：
372
/** * 等待唤醒之生产者和消费者模型 * 生成者: 创建和添加数据的线程 * 消费者: 销毁和删除数据的线程 * 问题1: 生成者生成数据过快, 消费者消费数据相对慢,不接收数据了, 会造成数据丢失 * 问题2: 消费者消费数据过快, 生成者生成数据相对慢,不发送数据了, 会造成数据被重复读取 ...
分类：
编程语言 时间：
2018-11-28 12:03:28
阅读次数：
177
一、简单生产者-消费者（使用direct交换器） 1、生产者 2、消费者 二、简单任务队列 1、任务发布者 主要代码与第一节的生产者代码一样。。只不过需要将发给工作者执行的任务放到消息里。 2、工作者 主要代码与第一节的消费者代码一样。。只不过工作者要解析任务，执行任务。 默认RabbitMQ会将每 ...
分类：
Web程序 时间：
2018-11-27 14:53:38
阅读次数：
825
1.paramiko模块 用处：连接远程服务器并执行相关操作 使用方法： SSHClient：连接远程服务器并执行基本命令 SSHFtp：连接远程服务器并执行上传下载功能 SSH_RSA：基于公钥密钥进行连接 RSA：非对称密钥验证 公钥：保存在要连接的服务器 私钥：保存在本地机器 2.进程： 什么 ...
分类：
编程语言 时间：
2018-11-26 02:20:59
阅读次数：
201
title: 字符设备驱动(七)按键异步通知 tags: linux date: 2018 11 24 16:39:47 toc: true [TOC] 按键驱动方式对比 1. 查询:耗资源 2. 中断: 没有超时机制，当没有中断作为生产者，read函数一直休眠 3. poll机制，加入超时机制 上 ...
分类：
其他好文 时间：
2018-11-25 20:37:48
阅读次数：
194
1、生产者—消费者问题 互斥、同步 1、无论生产者、消费者使用缓冲池时应保证互斥使用（互斥信号量mutex ）2、生产者和消费者间交叉有序：有序的控制最根源在产品数量上。设置两个信号量：分别针对生产者、消费者设置不同的信号量，empty和full分别表示缓冲池中空缓冲池和满缓冲池（即产品）的数量。e ...
分类：
其他好文 时间：
2018-11-25 16:26:51
阅读次数：
211
代码： from greenlet import greenlet import random def pro(): 生产者 while True: item = random.randint(0,99) print("生产了：",item) c.switch(item) 向消费者发送item ，并 ...
分类：
其他好文 时间：
2018-11-25 16:19:34
阅读次数：
180
思路： yield可以使得函数阻塞，next，和send可以解阻塞，实现数据不竞争的生产者消费者模式 代码： import random #随机数，模拟生产者的制造物 def eat(): #消费者 while True: item = (yield) print("消费了：",item) def ...
分类：
其他好文 时间：
2018-11-25 13:16:14
阅读次数：
225
1.原理假设有两个线程同时访问一个全局变量 n，这个全局变量的初始值等于0。Int n = 0 ; 消费者线程 A 进入临界区，访问 n，A 必须等到 n 大于 0 才能接着往下执行，如果 n== 0，那么 A 将一直等待。 还有一个生产者线程 B，B 进入临界区，修改 n 的值，使得 n >0，当 ...
分类：
其他好文 时间：
2018-11-24 23:54:20
阅读次数：
226
Kafka producer在设计上要比consumer简单，不涉及复杂的组管理操作，每个producer都是独立进行工作的，与其他producer实例之间没有关联。Producer的主要功能就是向某个topic的某个分区发送消息，所以首先要确认向topic的哪个分区写入消息——即分区器(parti ...
分类：
其他好文 时间：
2018-11-23 12:35:24
阅读次数：
180
