rocketmq

任意时间的定时，使用RocketMQ本身是实现不了的，以下提供了通过借助RocketMQ实现任意时间的定时消息。 总体叙述：通过计算当前时间和定时的时间之间的秒数，去匹配RocketMQ的延时等级，如果没有匹配到，找到第一个比目前时间秒数小或者相等的级别，作为延时等级向MQ推送消息，以此类推，知道找到合适的延时等级。 该方案具体的代码可以站内邮箱联系我

P2P，顾名思义，是一对一的消息收发模式，即只有一个消息发送者和一个消息接收者。而Pub/Sub模式通常用于一对多或多对多的消息群发场景，即拥有一个或多个消息发送者和多个消息接收者的场景。 在P2P模式中，发送者发送消息时已经明确该消息预期的接收者信息，并明确该消息只需要被特定的单个客户端消费

1、根据开发进度和任务分配，完成相应模块软件的开发、编程任务； 2、能根据设计方案和计划进行编码实现，在进度和质量上符合方案和计划的要求； 3、编写系统文档并进行系统对接。 1、本科及以上学历，三年以上JAVA开发经验； 2、有扎实的软件理论基础，理解面向对象编程，良好的面向对象理解能力； 4、有Junit、Memcached、maven，Dubbo、Zookeeper、RocketMQ等技术使用经验者为佳； 5、熟悉http及socket开发，对线程有深入了解； 6、熟悉Redis缓存，mysql数据库并能熟练使用； 7、熟练使用Git工具，有良好的编码习惯。

最近在设计一个多分区多副本的消息系统，以前对kafka有一些了解，在阅读了阿里的RocketMQ、小米的Pegasus等分布式系统后，再仔细阅读的kafka的复制设计，整理出本篇文档，可以和其它系统做一个对比。 Kafka是一种高吞吐量的分布式发布订阅消息系统，有如下特性： 通过O(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。 高吞吐量：即使是非常普通的硬件Kafka也可以支持每秒数百万的消息

相信大家也发现了，最近公众号博客都没怎么发文章，上次发还是在上次 6 月份。这是因为我把所有的工作之余时间投入到了这本小册：RocketMQ 核心原理解析。 有关注一段时间的朋友应该都还记得，之前公众号里发过 RocketMQ 相关的文章

利用多线程和队列可以实现生产者消费者模式。该模式通过平衡生产线程和消费线程的工作能力来提高程序整体处理数据的速度。 什么是生产者和消费者？ 在线程世界里，生产者就是生产数据（或者说发布任务）的线程，消费者就是消费数据（或者说处理任务）的线程

在了解了上面这些开源消息队列各自的特点和优劣势后我相信你对于消息队列的选择已经可以做到心中有数了。我也总结了几条选择的建议供你参考。 如果说消息队列并不是你将要构建系统的主角之一你对消息队列功能和性能都没有很高的要求只需要一个开箱即用易于维护的产品我建议你使用RabbitMQ

最近在设计一个多分区多副本的消息系统，以前对kafka有一些了解，在阅读了阿里的RocketMQ、小米的Pegasus等分布式系统后，再仔细阅读的kafka的复制设计，整理出本篇文档，可以和其它系统做一个对比。 Kafka是一种高吞吐量的分布式发布订阅消息系统，有如下特性： 通过O(1)的磁盘数据结构提供消息的持久化，这种结构对于即使数以TB的消息存储也能够保持长时间的稳定性能。 高吞吐量：即使是非常普通的硬件Kafka也可以支持每秒数百万的消息