JarCasting
JarCasting JarCasting

message-stream

Unified message flow API

License

License
GroupId

GroupId

tech.guyi.component
ArtifactId

ArtifactId

message-stream
Last Version

Last Version

1.0
Release Date

Release Date
Type

Type

pom
Description

Description

message-stream
Unified message flow API
Project URL

Project URL

https://github.com/guyi-maple/message-stream
Source Code Management

Source Code Management

https://github.com/guyi-maple/message-stream

Download message-stream

Filename Size
message-stream-1.0.pom 6 KB
Browse

How to add to project

<!-- https://jarcasting.com/artifacts/tech.guyi.component/message-stream/ -->
<dependency>
    <groupId>tech.guyi.component</groupId>
    <artifactId>message-stream</artifactId>
    <version>1.0</version>
    <type>pom</type>
</dependency>
// https://jarcasting.com/artifacts/tech.guyi.component/message-stream/
implementation 'tech.guyi.component:message-stream:1.0'
// https://jarcasting.com/artifacts/tech.guyi.component/message-stream/
implementation ("tech.guyi.component:message-stream:1.0")
'tech.guyi.component:message-stream:pom:1.0'
<dependency org="tech.guyi.component" name="message-stream" rev="1.0">
  <artifact name="message-stream" type="pom" />
</dependency>
@Grapes(
@Grab(group='tech.guyi.component', module='message-stream', version='1.0')
)
libraryDependencies += "tech.guyi.component" % "message-stream" % "1.0"
[tech.guyi.component/message-stream "1.0"]

Dependencies

compile (2)

Group / Artifact Type Version
org.springframework.boot : spring-boot-autoconfigure jar 2.4.1
org.slf4j : slf4j-api jar 2.0.0-alpha1

provided (2)

Group / Artifact Type Version
org.projectlombok : lombok jar 1.18.16
org.springframework.boot : spring-boot-configuration-processor jar 2.4.1

Project Modules

  • message-stream-api
  • message-stream-rabbitmq
  • message-stream-email
  • message-stream-websocket
  • message-stream-redis
  • message-stream-kafka

message-stream

为消息消费提供统一的API。

让切换不同的消息来源变得更简单。

根据上层业务无需变动代码, 只需修改配置即可做到切换消息的来源。

如： 将Rabbitmq切换为Kafka, 不需要修改业务侧代码, 只需修改配置即可切换。

还可支持多个消息来源的同时消费与发布。

如：同时消费来自Rabbitmq、Kafka、Websocket的消息, 同时向 Rabbitmq、Kafka、Websocket 发送消息。

随着下层消息流实现的增加, 可以实现更多的消息统一消费方式, 如文件、FTP、OSS、UDP、TCP等等, 终极目标是统一所有的输入及输出。

使用文档

已支持消息流

Versions

Version
1.0