Skip to main content
版本:v1.4.0

运行 eventmesh-sdk-java demo

Maven Central

EventMesh-sdk-java作为客户端,与eventmesh-runtime通信,用于完成消息的发送和接收。

EventMesh-sdk-java支持异步消息和广播消息。异步消息表示生产者只发送消息,不关心回复消息。广播消息表示生产者发送一次消息,所有订阅广播主题的消费者都将收到消息

EventMesh-sdk-java支持HTTP,TCP 和 GRPC 协议。

TCP, HTTP 和 GRPC 示例都在eventmesh-examples模块下

1. TCP

1.1 异步消息

  • 创建主题TEST-TOPIC-TCP-ASYNC,可以通过 rocketmq-console 或者 rocketmq tools 命令

  • 启动消费者,订阅上一步骤已经创建的Topic

运行 org.apache.eventmesh.tcp.demo.sub.eventmeshmessage.AsyncSubscribe 的main方法
  • 启动发送端,发送消息
运行 org.apache.eventmesh.tcp.demo.pub.eventmeshmessage.AsyncPublish 的main方法

1.2 广播消息

  • 创建主题TEST-TOPIC-TCP-BROADCAST,可以通过 rocketmq-console 或者 rocketmq tools 命令

  • 启动消费端,订阅上一步骤已经创建的Topic

运行 org.apache.eventmesh.tcp.demo.sub.eventmeshmessage.AsyncSubscribeBroadcast 的main方法
  • 启动发送端,发送广播消息
运行 org.apache.eventmesh.tcp.demo.pub.eventmeshmessage.AsyncPublishBroadcast 的main方法

更多关于TCP部分的内容,请参考 EventMesh TCP

2. HTTP

对于HTTP,eventmesh-sdk-java对对于异步事件实现了发送与订阅

在演示中,Java类LiteMessagecontent字段表示一个特殊的协议,因此,如果您要使用eventmesh-sdk-java的http-client,则只需设计协议的内容并在同一时间提供消费者的应用程序。

2.1 异步事件

生产者将事件发送给下游即可,无需等待响应

  • 创建主题TEST-TOPIC-HTTP-ASYNC,可以通过rocketmq-console或者rocketmq tools 命令

  • 启动消费端,订阅Topic

    异步事件消费端为spring boot demo,运行demo即可启动服务并完成Topic订阅

运行 org.apache.eventmesh.http.demo.sub.SpringBootDemoApplication 的main方法
  • 启动发送端,发送消息
运行 org.apache.eventmesh.http.demo.pub.eventmeshmessage.AsyncPublishInstance 的main方法

更多关于HTTP部分的内容,请参考 EventMesh HTTP

3. GRPC

eventmesh-sdk-java 实现了 gRPC 协议. 它能异步和同步发送事件到 eventmesh-runtime. 它可以通过webhook和事件流方式订阅消费事件, 同时也支持 CNCF CloudEvents 协议.

3.1 异步事件发送 和 webhook订阅

Async生产者 异步发送事件到 eventmesh-runtime, 不需要等待事件储存到 event-store 在webhook 消费者, 事件推送到消费者的http endpoint url。这个URL在消费者的 Subscription 模型定于. 这方法跟前面的Http eventmsh client类似。

  • 在rocketmq 创建主题 TEST-TOPIC-GRPC-ASYNC
  • 启动 publisher 发送事件
运行 org.apache.eventmesh.grpc.pub.eventmeshmessage.AsyncPublishInstance 的main方法
  • 启动 webhook 消费者
运行 org.apache.eventmesh.grpc.sub.app.SpringBootDemoApplication 的main方法

3.2 同步事件发送和事件流订阅

同步生产者 发送事件到 eventmesh-runtime, 同时等待事件储存到 event-store 在事件流消费者,事件以流的形式推送到 ReceiveMsgHook 客户端。 这方法类似 eventmesh client.

  • 在rocketmq 创建主题 TEST-TOPIC-GRPC-RR
  • 启动 Request-Reply publisher 发送事件
运行 org.apache.eventmesh.grpc.pub.eventmeshmessage.RequestReplyInstance 的main方法
  • 启动 stream subscriber
运行 org.apache.eventmesh.grpc.sub.EventmeshAsyncSubscribe 的main方法

3.3 批量事件发布

批量发布多个事件到 eventmesh-runtime. 这是异步操作

  • 在rocketmq 创建主题 TEST-TOPIC-GRPC-ASYNC
  • 启动 publisher 来批量发布事件
运行 org.apache.eventmesh.grpc.pub.eventmeshmessage.BatchPublishInstance 的main方法

更多关于 gRPC 部分的内容,请参考 EventMesh gRPC

4. 测试

请参考EventMesh StoreEventMesh Runtime 完成运行环境的部署

完成 store 和 runtime 的部署后,就可以在 eventmesh-examples 模块下运行我们的 demo 来体验 eventmesh 了:

gradle编译:

cd apache-eventmesh-1.9.0-src/eventmesh-examples
gradle clean dist

cd ./dist/bin

demo_1

4.1 TCP

TCP Sub

bash tcp_eventmeshmessage_sub.sh

打开对应log文件查看日志:

cd /root/apache-eventmesh-1.9.0-src/eventmesh-examples/dist/logs
tail -f demo_tcp_pub.out

demo_2

TCP Pub

bash tcp_pub_eventmeshmessage.sh

打开对应log文件查看日志:

cd /root/apache-eventmesh-1.9.0-src/eventmesh-examples/dist/logs
tail -f demo_tcp_sub.out

demo_3

4.2 TCP Broadcast

TCP Sub Broadcast

sh tcp_sub_eventmeshmessage_broadcast.sh

打开对应log文件查看日志:

cd /root/apache-eventmesh-1.9.0-src/eventmesh-examples/dist/logs
tail -f demo_tcp_sub_broadcast.out

demo_4

TCP Pub Broadcast

sh tcp_pub_eventmeshmessage_broadcast.sh

打开对应log文件查看日志:

cd /root/apache-eventmesh-1.9.0-src/eventmesh-examples/dist/logs
tail -f demo_tcp_pub_broadcast.out

demo_5

4.3 HTTP

HTTP Sub

sh http_sub.sh

打开对应log文件查看日志:

cd /root/apache-eventmesh-1.9.0-src/eventmesh-examples/dist/logs
tail -f demo_http_sub.out

demo_6

HTTP Pub

sh http_pub_eventmeshmessage.sh

打开对应log文件查看日志:

cd /root/apache-eventmesh-1.9.0-src/eventmesh-examples/dist/logs
tail -f demo_http_pub.out

demo_7

你可以在 /logs 目录下面看到不同模式的运行日志。