第四届阿里中间件性能挑战赛（复赛）
1. 题目背景
Apache RocketMQ作为的一款分布式的消息中间件，历年双十一承载了万亿级的消息流转，为业务方提供高性能低延迟的稳定可靠的消息服务。随着业务的逐步发展和云上的输出，单机队列数量的逐步增加，给RocketMQ带来了新的挑战。复赛的题目要求设计一个单机百万队列以上的存储引擎，单机内存有限，需要充分利用数据结构与存储技术，最大化吞吐量。
2. 题目描述
2.1 题目内容
实现一个进程内的队列引擎，单机可支持100万队列以上。
2.2 语言限定
JAVA和C++
3. 程序目标
仔细阅读demo项目中的QueueStore，DefaultQueueStoreImpl，DemoTester三个类。
你的coding目标是重写DefaultQueueStoreImpl，并实现以下接口:
abstract void put(String qu
2021-12-01 21:06:51
11KB
1
AMQP 简单的发布订阅
使用AMQP消息传递在服务之间交换数据的 Pub Sub 系统。
使用
您的项目至少需要使用 Node 版本 10，最好使用 Node 14 (LTS) 或更高版本。
npm install amqp-simple-pub-sub
创建发布者
const { makePublisher } = require ( 'amqp-simple-pub-sub' )
const publisher = makePublisher ( { exchange : 'testService' } )
发布消息
await publisher . start ( )
publisher . publish ( 'test' , 'Hello World' )
创建订阅者
const { makeSubscriber } = require ( 'amqp-simple-
2021-07-24 16:03:47
198KB
1
进程间通信之消息队列 ( message queue ）
消息队列是消息的链表,具有特定的格式,并由消息队列标识符标识.
七种进程间通信方式：
一.无名管道（ pipe ）
二.有名管道（ fifo ）
三.共享内存 ( shared memory )
四.信号 ( sinal )
五.消息队列 ( message queue ）
六.信号量 ( semophore )
七.套接字 ( socket )
以上七种进程间通信的完整代码，皆可以在我的资源列表中获取下载：
资源列表：http://download.csdn.net/user/qiulanzhu
2021-06-02 21:17:16
24KB
1
message-queue-parent
消息队列(ActiveMQ、Kafka、RabbitMQ、RocketMQ等)示例
2021-04-12 14:03:25
54KB
1