Socket
Socket
Sign inDemoInstall

com.pettyfox.timeline:timeline-mq

Package Overview
Dependencies
0
Maintainers
0
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

com.pettyfox.timeline:timeline-mq


Maintainers
0

Readme

Source

timeline-mq

License Maven Central

基于Java实现的。Timeline模式朋友圈、微博、消息推送、feed流、im通讯的抽象库,提供数据流间的分发功能、分发失败后重试,将抽象层、存储层分离提高系统灵活性、以及各种存储层的具体实现。

它的本质是一款消息队列,但是消息队列又过于抽象,因此我们将具体的某些业务进行抽离、加工、设计,转换为一类以消息队列为核心的业务实现方法。

状态

不稳定、开发分支dev-v2

版本记录

V1.0.0

实现基本的timeline抽象core层设计。

V2.0

吸取版本1的经验与不足,对整个框架进行重构,目标是使逻辑更加简便快捷

目前整个设计、代码实现还在规划,预计相对完善的可用的版本是V2.1

功能特点

  • 轻量级MQ,小到仅需要去下jar包便可以使用。或轻量级服务间消息队列通讯(无中间件、点对点通讯)。
  • 专有化的消息队列。旨在解决某类特有消息队列模型下的业务流处理方法。

数据同步

场景描述1

在仓库A中用户1的信息实时的同步到仓库B、C...中。当用户1的信息在A仓中被修改、删除时也会实时同步。 数据流程如下:

  1. 仓A新建用户1,数据同步至仓B,数据同步至仓C...

  2. 仓A修改用户1,数据同步至仓B,数据同步至仓C...

  3. 仓A删除用户1,数据同步至仓B,数据同步至仓C...

  4. 仓A创建用户2,数据同步至仓B,数据同步至仓C...

上述数据流微观描述:仓A作为数据生成者。仓B、仓C...作为数据消费者。

  • 数据单向流动
  • 数据存在顺序性
  • 生产者和消费者的数据被消息代理持久化,解耦生产或消费时的高可用处理逻辑。
  • 生产者和消费者关系解耦,实时的增删生产者与消费者关系

FAQs


Did you know?

Socket

Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.

Install

Related posts

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc