探索下一代服务器无服务事件中间件：Apache EventMesh

Apache EventMesh 是一个动态的事件驱动消息传递中间件，旨在提供一个统一的事件驱动的通信基础设施，以支持云原生，边缘计算以及微服务架构。

以下是一个简单的示例，展示如何使用 EventMesh 的 Golang SDK 发送和接收事件：

首先，确保已经安装了 EventMesh Golang SDK：

go get github.com/apache/incubator-eventmesh-sdk-go

以下是一个简单的 Golang 程序，演示了如何使用 EventMesh Golang SDK 发送和接收事件：

package main
 
import (
    "context"
    "fmt"
    "log"
    "time"
 
    "github.com/apache/incubator-eventmesh-sdk-go/mesh"
    "github.com/apache/incubator-eventmesh-sdk-go/pkg/e2e"
)
 
func main() {
    // 创建 EventMesh 客户端
    client, err := mesh.NewClient(
        mesh.WithAddr("eventmesh-server-address:port"),
        mesh.WithClientID("unique-client-id"),
    )
    if err != nil {
        log.Fatalf("failed to create EventMesh client: %v", err)
    }
    defer client.Close()
 
    // 发送事件
    event := e2e.NewEvent(
        e2e.WithContentType("application/json"),
        e2e.WithBody([]byte(`{"message": "Hello, EventMesh!"}`)),
    )
    if err := client.Publish(context.Background(), "topic-name", event); err != nil {
        log.Fatalf("failed to publish event: %v", err)
    }
 
    // 接收事件
    go func() {
        sub := e2e.NewSubscriber(
            e2e.WithSubscriberMode(e2e.SubscriberModeClustering),
            e2e.WithConsumerGroupName("consumer-group-name"),
        )
        for {
            select {
            case event := <-sub.Events():
                fmt.Printf("Received event: %s\n", event.Body)
            case err := <-sub.Errors():
                log.Printf("Error receiving event: %v", err)
            case <-time.After(5 * time.Second):
                log.Println("Subscriber timeout, exiting...")
                return
            }
        }
    }()
 
    if err := client.Subscribe(context.Background(), "topic-name", sub); err != nil {
        log.Fatalf("failed to subscribe: %v", err)
    }
 
    // 阻塞主线程，以保持订阅活动
    select {}
}

在这个示例中，我们创建了一个 EventMesh 客户端，用于发布和订阅命名为 "topic-name" 的事件。发布的事件包含一个简单的 JSON 消息，订阅者会接收这个事件并打印出来。

请注意，这只是一个简化的示例，实际使用时需要根据 EventMesh 服务器的配置和你的具体需求进行相应的调整。