RocketMQ整理 概念 broker MQ服务节点 topic 主题 message queue 消息队列，类似于kafka中的partition producer 生产者，先去连接name server，查询到对应的broker信息，再去连接broker consumer 消费者，先去连接na ...
分类：
其他好文 时间：
2019-07-23 11:39:13
阅读次数：
85
生产者消费者模型 import time,random from multiprocessing import Process,JoinableQueue def producer(name,food,q): for i in range(3): res='%s%s' %(food,i) time. ...
分类：
其他好文 时间：
2019-07-22 15:16:34
阅读次数：
92
一、语法基础 二、常用数据结构及使用方法 1. map: map[key]value 2. 数组：固定长度，较少使用 3. slice: 底层使用数组实现，但长度可扩展，传递切片即引用同一对象 4. struct: 结构体或类型 5. channel: 6. interface: 接口，可用于实现多 ...
分类：
其他好文 时间：
2019-07-20 21:49:06
阅读次数：
177
1. 安装与使用 2. 角色分类 3. 用户权限设置 4. pika 实现生产者消费者 ...
分类：
其他好文 时间：
2019-07-20 14:31:02
阅读次数：
107
纵观历次生产力革命，都是从生产者的技术革新开始，最后波及到消费者。几次工业革命中，能源和制造工艺的升级极大地提高了生产效率，并且创造了大量的新工种，最终提升了消费者的生活质量，促进一轮又一轮的消费升级。最近的信息技术革命，互联网最先使用在国外的大型工业产业，之后普及到社会生活中，才带来了无数次的生产力提升的机会和挑战。
分类：
编程语言 时间：
2019-07-19 12:39:20
阅读次数：
113
纵观历次生产力革命，都是从生产者的技术革新开始，最后波及到消费者。几次工业革命中，能源和制造工艺的升级极大地提高了生产效率，并且创造了大量的新工种，最终提升了消费者的生活质量，促进一轮又一轮的消费升级。最近的信息技术革命，互联网最先使用在国外的大型工业产业，之后普及到社会生活中，才带来了无数次的生产... ...
分类：
编程语言 时间：
2019-07-19 10:53:08
阅读次数：
122
一、搭建Zookeeper集群Zookeeper是一个分布式开源框架，提供了协调分布式应用的基本服务，它向外部应用暴露一组通用服务——分布式同步（DistributedSynchronization）、命名服务（NamingService）、集群维护（GroupMaintenance）等，简化分布式应用协调及其管理的难度，提供高性能的分布式服务。ZooKeeper本身可以以单机模式安装运行，不过它
分类：
其他好文 时间：
2019-07-16 10:26:02
阅读次数：
108
为了获得更良好的阅读体验，建议您前往个人独立域名博客观看： "传送门" ) 一、什么是消息队列？ 当我试图用一则通俗的比喻来说明这个概念的时候，我想到一个有意思的比喻： 如果把队列抽象成一个集合体，那么消息队列也就是一堆消息的集合。 按照这个思路我想到了「杂志」。这不就是一堆消息的集合吗，关心这些消 ...
分类：
其他好文 时间：
2019-07-16 10:22:18
阅读次数：
86
最近公司做了一个以信息安全为主的项目，其中有一个业务需求就是，项目定时监控操作用户的行为，对于一些违规操作严重的行为，以发送邮件(FoxMail)的形式进行邮件告警，可能是多人，也可能是一个人，第一次是以单人的形式，,直接在业务层需要告警的地方发送邮件即可，可是后边需求变更了，对于某些告警邮件可能会发送多人，这其中可能就会有阻塞发邮件的可能，直到把所有邮件发送完毕后再继续做下边的业务，领导说这样会影响用户体验，发邮件的时候用户一直处于等待状态，不能干别的事情。最后研究说用消息队列，当有需要发送邮件告警的时候,就向队列中添加一个标识消息，ActiveMQ通过监听器的形式，实时监听队列里边的小时，收到消息后，判断是不是需要发送告警的标识，是的话就自行就行发送邮件！这是就研究的消息队列ActiveMQ,下边就是具体内容：
分类：
编程语言 时间：
2019-07-15 14:45:45
阅读次数：
155
package javalearn; import java.util.LinkedList; import java.util.Queue; public class ProducerConsumer { private static final int MAX = 5; ////////////... ...
分类：
编程语言 时间：
2019-07-15 12:01:51
阅读次数：
117
