其实Rocketmq的给第三方的插件已经全了，如果大家有兴趣的话请移步https://github.com/apache/rocketmq-externals。本文主要是结合笔者已有的rmq在spark中的应用经验对rocketmq做简单介绍以及经验总结，当然免不了会将rocketmq ...

架构 核心模块 rocketmq-broker：接受生产者发来的消息并存储（通过调用rocketmq-store），消费者从这里取得消息 rocketmq-client：提供发送、接受消息的客户端API。 rocketmq-namesrv：NameServer，类似于 ...

问题 RocketMQ重复消费问题 RocketMQ线程过高问题 线上场景 场景一：重复消费 场景：生产有这么一种场景，我们在RocketMQ中对一个topic创建了16个tag，不同总类的信息放到不同的tag中，在消费端每个tag对应三个线程组成group去消费 ...

RocketMQ提供了Java客户端，用于发送和接收消息。 发送消息有三种方式：同步、异步和单向。 1、同步发送消息 2、异步发送消息 3、单向发送消息 接收消息 // Instantiate with specified ...

RocketMQ 消息队列作为高并发系统的组件之一，能够帮助业务系统解构提高开发效率和系统稳定性。 优势： 削峰填谷：解决瞬时写压力导致的消息丢失、系统崩溃等问题 系统解耦：处理不同重要程度和不同能力级别系统之间的消息 提升性能：当存在一对多调用是，可以发一条消息给消息系统 ...

一、如何定义java中的方法 所谓方法，就是用来解决一类问题的代码的有序组合，是一个功能模块。 语法： 1、 访问修饰符：方法允许被访问的权限范围， 可以是 public、protected、private 甚至可以省略 ，其中 public 表示该方法可以被其他任何代码调用 ...

锁作为并发共享数据，保证一致性的工具，在JAVA平台有多种实现(如 synchronized（重量级） 和 ReentrantLock(轻量级)等等 ) 。这些已经写好提供的锁为我们开发提供了便利。 1.重入锁 重入锁，也叫做递归锁，指的是同一线程 外层函数获得锁之后 ，内层递归函数仍然有获取 ...

一、40亿数据排序问题 给定一个最多包含40亿个随机排列的32位整数的顺序文件，找出一个不在文件中的32位整数(在文件中至少缺失这样一个数——为什么？)。在具有足够内存的情况下，如何解决该问题？（编程珠玑） 二、应用BitMap存储大数据 数据的存在性可以使用bit位上的1或0来表示；一个 ...