1.主库 [oracle@xag1124a ~]$ sqlplus / as sysdba SQL> select protection_mode,protection_level,log_mode,open_mode,flashback_on from v$database; PROTECTION ...
分类:
数据库 时间:
2020-07-25 23:57:18
阅读次数:
177
1、任务(tasks)–用户定义的函数,用于实现用户的功能,比如执行一个耗时很长的任务 2、中间介(Broker)–用于存放tasks的地方,但是这个中间介需要解决一个问题,就是可能需要存放非常非常多的tasks,而且要保证Worker能够从这里拿取 3、执行者(Worker)–用于执行tasks, ...
分类:
其他好文 时间:
2020-07-23 15:52:53
阅读次数:
69
启动RocketMQ 启动nameserver 修改broker配置参数,新增 messageDelayLevel=1s 2s 4s 8s 16s 32s 64s 128s 256s 512s 1024s 2048s 4096s 8192s 16384s 32768s 65536s 131072s ...
分类:
其他好文 时间:
2020-07-22 15:54:34
阅读次数:
43
启动RocketMQ 启动nameserver 修改broker配置参数,新增 messageDelayLevel=1s 2s 4s 8s 16s 32s 64s 128s 256s 512s 1024s 2048s 4096s 8192s 16384s 32768s 65536s 131072s ...
分类:
其他好文 时间:
2020-07-22 15:51:28
阅读次数:
83
<div id="cnblogs_post_body" class="blogpost-body "> <p><strong>Broker Configs</strong></p><p> </p><p> </p><table style="width: 800px; ...
分类:
其他好文 时间:
2020-07-20 17:18:44
阅读次数:
72
关于MQ的定义MessageQueue(MQ)消息队列中间件,通常我们在网上看到的对其定义是将消息的发送和接受分离来实现应用程序的异步和解耦,给人的直觉是MQ是异步的,用来解耦的。但这个只是MQ的效果,而不是目的。MQ真正的目的是为了通讯,屏蔽底层复杂的通讯协议,定义了一套应用层上更加简单的通讯协议。一套分布式系统中两个模块之间通讯要么是HTTP,要么是TCP,但这两种协议其实都是原始的协议。前者
分类:
其他好文 时间:
2020-07-19 11:25:55
阅读次数:
72
工欲善其事,必先利其器。 什么是Celery Celery是一个简单、灵活且可靠的,处理大量消息的分布式系统,专注于实时处理的异步任务队列,同时也支持任务调度。 上面的图是一个利用Celery进行异步处理的架构,属于生产者-消费者模式,架构由三部分组成: 消息中间件(message broker): ...
分类:
其他好文 时间:
2020-07-19 00:54:19
阅读次数:
106
springboot整合activeMqActiveMq是Apache提供的开源消息系统采用java实现,很好地支持JMS(JavaMessageService,即Java消息服务)规范ActiveMq安装:http://activemq.apache.org/components/classic/download/在官网下载安装对应的版本下载完成后解压就可以使用ActiveMq默认的端口号是81
分类:
编程语言 时间:
2020-07-17 01:16:57
阅读次数:
105
仅罗列一些常用基本配置,更多配置请到查看 https://www.orchome.com/472 server.properties配置文件 ###kafka服务和系统相关### #broker id,代表当前主机,集群里唯一 broker.id=1 #监听地址和端口,producter、consu ...
分类:
其他好文 时间:
2020-07-11 13:08:02
阅读次数:
51
图灵学院 java架构师学习路线 概述 ActiveMQ有支持两种事务, JMS transactions - the commit() / rollback() methods on a Session (which is like doing commit() / rollback() on a ...
分类:
其他好文 时间:
2020-07-08 14:56:33
阅读次数:
72