2018 年，做为架构负责人，接到一个架构需求：实现一个简单易用的 RocketMQ SDK 。
转自：https://github.com/alibaba/RocketMQ/wiki/rmq_vs_kafka 淘宝内部的交易系统使用了淘宝自主研发的Notify消息中间件，使用MySQL作为消息存储媒介，可完全水平扩容，为了进一步降低成本，我们认为存储部分可以进一步优化，2011年初，Linkin开源了Kafka这个优秀的消息中间件，淘宝中间件团队在对Kafka做过充分Review之后，Kafka无限消息堆积，高效的持久化速度吸引了我们，但是同时发现这个消息系统主要定位于日志传输，对于使用在淘宝交易、订
我们的系统完成某项操作之后，会推送事件消息到业务方的接口。当我们调用业务方的通知接口返回值为成功时，表示本次推送消息成功；当返回值为失败时，则会多次推送消息，直到返回成功为止(保证至少成功一次)。
背景：公司最早的一个版本的订单管理，是通过PHP+mysql的方案去实现的，这样会有什么问题呢，假设如果放到一个实例里面，全部用一个单机事务去解决，这样是能比较方便的解决数据一致性问题。但是存在两个问题，一是无法进行多实例部署，用户量增长以后，无法快速应对。二是，PHP中做事务，如果PHP遇到异常，有时并不会自动终止事务，导致DB被锁住，这是第一个版本。之后，我们推出了第二个版本V2，这个版本的时候，我们已经开发好了，库存管理系统，优惠券管理系统，PHP中，已经不直接通过DB去修改库存和优惠券，而是通过接口访问的方式去请求SERVER进行修改。这个版本，实际上已经从逻辑上，把订单系统和库存管理，优惠券管理系统已经独立出来了。数据层面已经可以独立部署，不再依赖一个单机事务去实现数据一致性功能了。但这个版本虽然解决了数据分布的问题，但同时引入了一个新的问题，就是数据在订单，库存，优惠券之间无法保证一致性。举个例子：下个订单，调用库存成功，锁定优惠券失败，生成订单失败。这时候就会导致优惠券数据不一致性情况出来，未下单的优惠券也被锁住了。有同事可能会问：订单如果创建失败，那直接回滚优惠券操作，即去解锁优惠券系统即可实现数据一致性。不错，很多时候，是可以这么操作，但如果你回滚的时候，失败了呢？你是继续在这等着直到成功，还是继续等着？呵呵。。
RocketMQ作为一款分布式的消息中间件（阿里的说法是不遵循任何规范的，所以不能完全用JMS的那一套东西来看它），经历了Metaq1.x、Metaq2.x的发展和淘宝双十一的洗礼，在功能和性能上远超ActiveMQ。
前言 循环依赖分为2类: RPC服务间（dubbo、http）循环依赖 应用间循环依赖 Dubbo缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，防止Spring初始化完成。这种情况我们就叫做RPC服务间循环依赖。出现了循环依赖，必须有一方先启动。所以这种问题是一定需要解决的。 应用间循环依赖大致情况如下: A应用调用B应用的服务，B应用也会调用A应用的服务，无论是间接调用还是直接调用。 这种循环依赖刚开始不会出现问题 ，但随着代码变更，有可能会发展为RPC服务间循环依赖。 可以通过check=
一：有一个很大的商品订单表，每天新增数十万条数据。每条数据有个到期时间，需要在到期时间后做一些处理，譬如关闭订单，改变状态之类的。
因业务发展需要现在的系统不足以支撑现在的用户量，于是我们在一周之前着手项目的性能优化与分布式部署的相关动作。 概况 现在的系统是基于RabbitHub（一套开源的开发时框架）和Rabbit.WeiXin（开源的微信开发SDK）开发的一款微信应用类系统，主要业务是围绕当下流行的微信元素，如：微官网、微商城、微分销、营销活动、会员卡等。 关于RabbitHub详情请戳： .NET 平台下的插件化开发内核（Rabbit Kernel） RabbitHub开源情况及计划 关于Rabbit.WeiXin详情请戳： .
RocketMQ 5.0： 云原生“消息、事件、流”实时数据处理平台，覆盖云边端一体化数据处理场景。
官方文档: https://rocketmq.apache.org/zh/docs/introduction/02concepts
后来通过查询资料得知，可能阿里的rocketMq服务版本比较高，ons客户端版本已经到了4.8而spring-cloud-starter-stream-
之前有篇文章Springboot 排除不想加载的配置只是排除，如果有些复杂场景需要根据条件来判断 就需要Spring 支持的另外一种方式 ——@Conditional注解。
直接去node官网上下载下来人后安装就行了,推荐使用稳定版。如果追求高版本的话可以下载测试版
RocketMQ 消费异常，但是重试间隔时间太长（HTTP协议重试策略），需要快速定位到系统异常问题，所以需要手动在控制台发送消息并且发送。
最近虚拟机下的Oracle 10g RAC搬家，搬家完毕之后，Oracle 集群resource之VIP无法正常启动，收到了CRS-0233: Resource or relatives are currently involved with another operation 错误提示。为为啥呢，原来啊，搬家了地址发生变化了，你得使用你家里的新地址阿....
大致情况：安装Android开发环境，网上有很多的教程，装eclipse，jdk…别的问题都不大，最麻烦的是装sdk，因为安装是一个在线安装过程，而要安装的文件都非常巨大（20多个60M以上的Zip包），而且在线装速度有时慢，所以比较费劲。尝试了一些方案，我觉得先离线装，再在线补的方法挺好。以下是一些心得： 需求：网速要快，因为下载量非常大。硬盘要大，因为安装的、解压的东西也多也大。 Eclipse：http://www.eclipse.org/downloads/ ,应该下载for Java EE版。
Oracle 11g RAC中，发现oc4j以及gsd服务都处于offline状态，这是Oracle 11g RAC默认情形。即便如此，并不影响数据库的使用，因为 oc4j 是用于WLM 的一个资源, WLM在 11.2.0.2 才可用。GSD则是用于支持dbca,srvctl,oem等的交互工具。本文描述将这两个服务切换到online。
目前针对移动设备的Cordova应用程序和渐进式的Web应用程序非常流行。提升用户体验和交互的关键是传递出原生的视觉效果和感觉，这并不总是一件容易的事情。当然，新建有样式装饰的多选复选框（checkboxes）和单选按钮（radio buttons）是很容易的，但是提供我们所追求的质量飞跃的真正特性是基于用户交互的。
早晨起来，听着杰伦的新歌《等你下课》，轻快的旋律，动听的曲调，让我回想18岁的我........
“软件定义网络、网络功能虚拟化和开源运动的时代已经到来”Guru Parulkar在6月16号的ONS大会开幕式上开始了他的演说。 诚然，这些技术还很年轻也存在着各自的缺陷，但并不影响各个组织考虑通过
昨天安装 room-assistant 的过程中有提及到，因为 HA 中提前安装了 MQTT 服务端，所以它可以自动使用正确的凭据连接上去，而无需任何配置，是不是非常方便
Chrome扩展是一种可以在Chrome浏览器中添加新功能和修改浏览器行为的软件程序，例如我们常用的TamperMonkey、Proxy SwitchyOmega、AdGuard等等，这些拓展都是可以通过WebExtensions API来修改、增强浏览器的能力，用来提供一些浏览器本体没有的功能，从而实现一些有趣的事情。
继我上一篇博客后 分布式消息队列RocketMQ学习教程① 上一篇博客最主要介绍了几种常用的MQ，所以本博客再简单介绍一下RocketMQ的原理和简单的例子，基于Java实现，希望可以帮助学习者
在之前的博文 【AI】浅析恶意文件静态检测及部分问题解决思路 中，博主提及过恶意文件静态检测的一种方法，并因此训练了模型，由于样本量巨大以及资源有限，训练一个 epoch 就需要一周多的时间，因此就先拿训练过一个 epoch 的模型来进行测试；
如果使用 Docker 技术来架构微服务体系，服务发现就是一个必然的课题。目前主流的服务发现模式有两种：客户端发现模式，以及服务端发现模式。 客户端发现模式 客户端发现模式的架构图如下： 客户端发现模式的典型实现是Netflix体系技术。客户端从一个服务注册服务中心查询所有可用服务实例。客户端使用负载均衡算法从多个可用的服务实例中选择出一个，然后发出请求。比较典型的一个开源实现就是 Netflix 的 Eureka。 Netflix-Eureka Eureka 的客户端是采用自注册的模式，客户端需要负责
RAC数据库与单实例的差异主要表现在多个实例通过集群件来统一管理共享的资源。因此原有的单实例的管理方式，如数据库、监听器等的关闭启动等可以使用原有的方式进行，也可以通过集群管理工具，命令行来集中管理，这也是推荐的管理方式。由于集群件crs位于数据库之上，即RAC数据库依赖于集群件，因此数据库的启动与关闭应该结合集群来考虑，下面以10g RAC来描述数据库启动与关闭过程，不涉及集群层的启动与关闭。
所有实例和服务的状态 $ srvctl status database -d orcl Instance orcl1 is running on node linux1 Instance orcl2 is running on node linux2 单个实例的状态 $ srvctl status instance -d orcl -i orcl2 Instance orcl2 is running on node linux2 在数据库全局命名服务的状态 $ srvctl status serv
https://www.cwiki.us/display/CONFLUENCEWIKI/View+Space+Activity
Name Type Target State Host
安装好sles 10 sp3 + Oracle 10g RAC之后，在配置监听器时，总是提示主机bo2dbp上的监听服务已经在运行，忽略错误之后手动在bo2dbp节点上启，总是收到TNS-12
Kafka作为一种分布式消息队列系统，在大数据领域和实时数据处理中扮演着重要的角色。随着Kafka的广泛应用，用户对其功能的需求也在不断增加。延时操作作为其中之一，为用户提供了更多的灵活性和实用性。本文将介绍Kafka中延时操作的相关内容，包括其背后的原理、实现方式以及应用场景。
延时消息（定时消息）指的在分布式异步消息场景下，生产端发送一条消息，希望在指定延时或者指定时间点被消费端消费到，而不是立刻被消费。
—1— 前言 延时消息（定时消息）指的在分布式异步消息场景下，生产端发送一条消息，希望在指定延时或者指定时间点被消费端消费到，而不是立刻被消费。 延时消息适用的业务场景非常的广泛，在分布式系统环境下，延时消息的功能一般会在下沉到中间件层，通常是 MQ 中内置这个功能或者内聚成一个公共基础服务。 本文旨在探讨常见延时消息的实现方案以及方案设计的优缺点。 —2— 实现方案 1. 基于外部存储实现的方案 这里讨论的外部存储指的是在 MQ 本身自带的存储以外又引入的其他的存储系统。 基于外部存储的方案本质上都是
$ srvctl status instance -d orcl -i orcl2
点击上方“芋道源码”，选择“设为星标” 管她前浪，还是后浪？ 能浪的浪，才是好浪！ 每天 10:33 更新文章，每天掉亿点点头发... 源码精品专栏 原创 | Java 2021 超神之路，很肝~ 中文详细注释的开源项目 RPC 框架 Dubbo 源码解析 网络应用框架 Netty 源码解析 消息中间件 RocketMQ 源码解析 数据库中间件 Sharding-JDBC 和 MyCAT 源码解析 作业调度中间件 Elastic-Job 源码解析 分布式事务中间件 TCC-Transaction
松哥最近正在录制 TienChin 项目视频～采用 Spring Boot+Vue3 技术栈，里边会涉及到各种好玩的技术，小伙伴们来和松哥一起做一个完成率超 90% 的项目，戳戳戳这里-->TienChin 项目配套视频来啦。 ---- 延时消息（定时消息）指的在分布式异步消息场景下，生产端发送一条消息，希望在指定延时或者指定时间点被消费端消费到，而不是立刻被消费。 延时消息适用的业务场景非常的广泛，在分布式系统环境下，延时消息的功能一般会在下沉到中间件层，通常是 MQ 中内置这个功能或者内聚成一个公共基
因为工作中需要用到分布式的延时队列，调研了一段时间，选择使用 Redisson DelayedQueue，为了搞清楚内部运行流程，特记录下来。
环境：OEL 5.7 + Oracle 10.2.0.5 Clusterware + Oracle 10.2.0.5 RAC 故障：数据库open时报错ORA-1172，ORA-1151
Linux平台 Oracle 10gR2（10.2.0.5）RAC安装 Part3：db安装和升级 环境：OEL 5.7 + Oracle 10.2.0.5 RAC
首先搜索字符串，找到 flag 字样，然后上溯到函数头。之后对这段汇编代码进行分析，等效的伪代码是：
1、yml配置 alimq: ProducerId: PRODUCER（mq中定义） ConsumerId: CONSUMER（mq中定义） AccessKey: SecretKey: ONSAddr: http://onsaddr-internet.aliyun.com/rocketmq/nsaddr4client-internet SendMsgTimeoutMillis: 3000 topic: TOPIC #mq开关 0-
上篇文章介绍了RocketMQ整体架构和原理有兴趣的可以阅读一下，在这篇文章中的延时消息部分，我写道开源版的RocketMQ只提供了18个层级的消息队列延时，这个功能在开源版中显得特别鸡肋，但是在阿里云中的RocketMQ却提供了支持40天之内任意秒级延时队列，果然有些功能你只能充钱才能拥有。当然你或许想换一个开源的消息队列，在开源社区中消息队列延时消息很多都没有被支持比如：RabbitMQ,Kafka等，都只能通过一些特殊方法才能完成延时的功能。为什么这么多都没有实现这个功能呢？是因为技术难度比较复杂吗？接下来我们分析一下如何才能实现一个延时消息。
我们都知道Redis是一种基于内存的单进程单线程数据库（Redis6.0开始之后支持多线程啦！），处理速度都非常快。那么为何Redis又能慢呢？原来，这里说的慢是指Redis可以设置一些参数达到慢处理的结果。
在 RocketMQ 4.x 版本，使用延时消息来实现消息的定时消费。延时消息可以一定程度上实现定时发送，但是有一些局限。
延时队列：顾名思义，是一个用于做消息延时消费的队列。但是它也是一个普通队列，所以它具备普通队列的特性，相比之下，延时的特性就是它最大的特点。所谓的延时就是将我们需要的消息，延迟多久之后被消费。普通队列是即时消费的，延时队列是根据延时时间，多久之后才能消费的。
通常我们使用Handler的消息延时都是调用sendMessageDelayed函数实现的，其中delayMillis是需要延时的毫秒。
延时消息是指发送到 RocketMQ 后不会马上被消费者拉取到，而是等待固定的时间，才能被消费者拉取到。
地址：www.cnblogs.com/xiaowei123/p/13222710.html
近期在维护公司的调度平台，其中有个关键功能那就是定时任务；定时任务大家平时肯定接触的不少，比如 JDK 中的 Timer、ScheduledExecutorService、调度框架 Quartz 等。
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
云直播
