进程通信(Interprocess Communication,IPC)是一个进程与另一个进程间共享消息的一种通信方式。消息(message)是发送进程形成的一个消息块,将消息内容传送给接收进程。IPC机制是消息从一个进程的地址空间拷贝到另一个进程的地址空间。 进程通信的目的: 1、数据传输 一个进 ...
分类:
系统相关 时间:
2020-08-11 14:19:23
阅读次数:
90
RabbitMQ是什么? MQ(Message Queue,消息队列)消息中间件,一般以集群方式部署,主要提供消息的接受和发送,实现各微服务之间的消息同步。 原理介绍 rabbitmq是依据erlang的分布式特性(RabbitMQ底层是通过Erlang架构来实现的,所以rabbitmqctl会启动 ...
分类:
其他好文 时间:
2020-08-04 16:52:47
阅读次数:
96
python使用wxpy模块提供的微信API接口实现两两群组的消息同步 安装模块: pip install wxpy 注意:需要同步的微信群需要保存到通讯录中 以下是自己闲来无事写的代码,暂时还存在以下几个问题,有能优化的大佬可以讨论下: 1.暂时同步不了大文件,测试发现超过40M的文件无法同步; ...
分类:
微信 时间:
2020-06-12 20:26:52
阅读次数:
122
Netty获取异步执行结果 步骤:(具体代码参考下面demo) 1. 给消息设置个唯一key 2. 初始化响应消息队列:responseMsgCache.put(key,new LinkedBlockingQueue(1)); 3. 执行异步IO:future.addListener 4. 阻塞等待 ...
分类:
Web程序 时间:
2020-04-26 20:42:13
阅读次数:
463
理论篇 概述 概述 应用场景 提供服务包括:分布式消息同步和协调机制,服务器节点动态上下线,统一配置管理,负载均衡,集群管理等 本地模式安装部署 安装准备: 安装JavaJDK 将下载zookeeper安装tar包上传到linux系统中 解压tar包并修改文件权限 修改配置文件 将zookeeper ...
分类:
其他好文 时间:
2019-11-27 23:45:55
阅读次数:
171
事故背景: 我们公司与合作方公司有个消息同步的需求,合作方是消息生产者,我们是消息消费者,他们通过kafka给我们推送消息,我们实时接收,然后进行后续业务处理。昨天上午,发现他们推送过来的广场门店信息我们都没有消费,导致我们系统和他们系统数据不一致,从而导致无法提单,无法出报表(报表有误)等各种问题 ...
分类:
其他好文 时间:
2019-06-12 10:53:36
阅读次数:
143
原文:https://www.jianshu.com/p/7aeadca0c9bd# 看到了该网址有基于itchat的微信消息同步机器人,转过来继续研究。以下是转过来的: 最近 全栈数据工程师养成攻略 的微信群已经将近500人,开了二群之后为了打通不同微信群之间的消息,花了点时间做了个消息同步机器人 ...
分类:
微信 时间:
2019-05-15 16:12:05
阅读次数:
325
持久化消息和非持久化消息的发送策略 消息同步发送和异步发送 ActiveMQ支持同步、异步两种发送模式将消息发送到broker上。同步发送过程中,发送者发送一条消息会阻塞直到broker反馈一个确认消息,表示消息已经被broker处理。这个机制提供了消息的安全性保障,但是由于是阻塞的操作,会影响到客 ...
分类:
其他好文 时间:
2019-04-08 01:04:59
阅读次数:
186
Kafka应用场景 消息系统或是说消息队列中间件是当前处理大数据一个非常重要的组件,用来解决应用解耦、异步通信、流量控制等问题,从而构建一个高效、灵活、消息同步和异步传输处理、存储转发、可伸缩和最终一致性的稳定系统。当前比较流行的消息中间件有Kafka、RocketMQ、RabbitMQ、ZeroM ...
分类:
其他好文 时间:
2019-01-29 14:55:35
阅读次数:
129
背景 一个果园会产出5种水果,ABCDE,每种水果有不同处理方式。 果园每天只采摘一次,每次只采摘一种水果,当天会摘哪一种,会看长势临时决定。 水果种类=事件类型 果农和工人=线程/代码函数 贴纸条=发布消息 看纸条=接收消息 同步方案 果园里只有一个老果农打理,他每天进园采摘一种水果。如果摘到AB ...
分类:
其他好文 时间:
2018-12-28 16:03:20
阅读次数:
156