1.大多应用中,可通过消息服务中间件来提升系统异步通信、扩展解耦能力 1.1异步通信 1.2解耦 1.3削峰 2.消息服务中两个重要概念: 消息代理(message broker)和目的地(destination)当消息发送者发送消息以后,将由消息代理接管,消息代理保证消息传递到指定目的地。 消息队 ...
分类:
编程语言 时间:
2018-09-02 01:53:52
阅读次数:
304
在使用RabbitMQ的时候,我们可以通过消息持久化操作来解决因为服务器的异常奔溃导致的消息丢失,除此之外我们还会遇到一个问题,当消息的发布者在将消息发送出去之后,消息到底有没有正确到达broker代理服务器呢? ...
分类:
其他好文 时间:
2018-09-01 17:34:56
阅读次数:
158
1 RabbitMQ知识点 1.1 整体架构图 消息生产者将消息投递到exchange中,exchange会以某种路由机制将生产者投递的消息路由到queue中,消息消费者再从queue中获取消息进行消费。 1.2 核心概念 1.2.1 server 又称Broker,接收客户端的连接,实现AMQP实 ...
分类:
编程语言 时间:
2018-08-31 00:33:33
阅读次数:
313
一、主机描述 dbprimary: 192.168.1.57 主机名称db1 dbstandby: 192.168.1.58 主机名成db2 SID: orcl 二、配置tns,配置好的文件内容: dbprimary的listener.ora (/db/app/oracle/product/11.2 ...
分类:
数据库 时间:
2018-08-22 10:20:58
阅读次数:
181
简要: 当查询数据库数据时,提示临时表空间异常,报错ORA-01157 ORA-01110,经过对数据文件处理后,已经解决此故障。 环境:Oracle 11g RAC For Linux 6,该库为DataGuard备库 1. 查询数据时报错,如下: ERROR:ORA-01157: cannot ...
分类:
数据库 时间:
2018-08-21 00:29:05
阅读次数:
353
kafka删除topic/usr/local/kafka/bin/zookeeper-shell.shIP:2181WatchedEventstate:SyncConnectedtype:Nonepath:nullls/admin/delete_topics[]ls/brokers/topics/prod-polling-gt-polling-access-prodquit/usr/local/k
分类:
其他好文 时间:
2018-08-20 12:21:41
阅读次数:
144
Celery分布式任务 celery call把任务给一个组件,组件交给rabiitmq放到队列broker,队列返回任务id给celery组件再给call,任务完成时call拿着id通过celery去rabbitmq取。broker发任务给worker 1.Celery有以下优点: 简单:一单熟悉 ...
分类:
其他好文 时间:
2018-08-17 13:57:02
阅读次数:
879
1. 环境 celery>=4.0 对此环境会有报错, 暂不建议在此环境下使用 2. 安装 3. 安装Redis, 用作Broker (RabbitMQ 官方推荐, 但安装麻烦点) 4. 新建django项目 配置settings.py 新建文件Demo/Demo/celery.py 新建Demo/ ...
分类:
其他好文 时间:
2018-08-17 13:51:35
阅读次数:
175
这段程序没有验证,应该不会有问题。 是HA与updateStateByKey相结合的程序。 1.程序 ...
分类:
其他好文 时间:
2018-08-15 21:36:37
阅读次数:
179
安装环境 jdk1.7 alibaba-rocketmq-3.2.6.tar.gz VM虚拟机redhat6.5-x64:192.168.1.201 192.168.1.202 192.168.1.203 192.168.1.204 Xshell4 部署方案 IP 主机名 用途 Broker角色 1 ...
分类:
其他好文 时间:
2018-08-15 13:05:58
阅读次数:
182