openevent

package module

v1.1.2 Latest Latest Go to latest Published: Apr 20, 2026 License: MIT Imports: 3 Imported by: 0

README ¶

open-event-sdk-go

开放平台事件订阅 SDK（Go 语言版），支持通过 WebSocket 长连接接收和处理事件。

特性

WebSocket 长连接：无需公网 IP，延迟更低、实时性更好
自动重连：网络断开时自动重连，支持指数退避策略
KSO-1 签名认证：安全的认证机制
灵活的事件处理：支持单一 Handler 和 Dispatcher 分发两种模式
开箱即用：内置默认配置，无需额外设置即可使用
CLI 工具：零代码接收事件，终端实时查看，适合快速验证和调试

CLI 工具 (openevent)

openevent 是基于本 SDK 的命令行工具，无需编写代码即可接收事件推送，适合快速验证事件配置。

安装

方式一：一键安装脚本（推荐，自动检测平台架构）

macOS / Linux / Windows (Git Bash)：

curl -fsSL https://raw.githubusercontent.com/GongchuangSu/open-event-sdk-go/main/scripts/install.sh | bash

Windows（PowerShell 原生）：

irm https://raw.githubusercontent.com/GongchuangSu/open-event-sdk-go/main/scripts/install.ps1 | iex

指定版本或安装目录：

# macOS / Linux / Windows (Git Bash)
VERSION=1.1.0 INSTALL_DIR=~/.local/bin bash -c "$(curl -fsSL https://raw.githubusercontent.com/GongchuangSu/open-event-sdk-go/main/scripts/install.sh)"

# Windows PowerShell
$env:VERSION="1.1.0"; irm https://raw.githubusercontent.com/GongchuangSu/open-event-sdk-go/main/scripts/install.ps1 | iex

注意：安装脚本依赖 GitHub Releases 产物，需要仓库已发布过 tag（见下方「发布新版本」章节），否则脚本会因无法获取版本号而失败。

方式二：go install

go install github.com/GongchuangSu/open-event-sdk-go/cmd/openevent@latest

方式三：从源码构建

git clone https://github.com/GongchuangSu/open-event-sdk-go.git
cd open-event-sdk-go
make build            # 产物在 output/openevent
make install          # 安装到 $GOPATH/bin

方式四：从 GitHub Releases 手动下载

支持的平台和架构：

平台	架构	文件格式
macOS (darwin)	amd64 / arm64	`.tar.gz`
Linux	amd64 / arm64	`.tar.gz`
Windows	amd64 / arm64	`.zip`

使用

凭证提供方式（按优先级从高到低）：

优先级	方式	示例
1	命令行参数	`--app-id xxx --app-secret yyy`
2	环境变量	`APP_ID=xxx APP_SECRET=yyy`
3	交互式输入	自动检测 TTY，密码隐藏显示

# 使用命令行参数
openevent listen --app-id YOUR_APP_ID --app-secret YOUR_APP_SECRET

# 使用环境变量
export APP_ID=your_app_id
export APP_SECRET=your_app_secret
openevent listen

# 交互式输入（仅 TTY 终端，密码不回显）
openevent listen

# 过滤特定事件
openevent listen --events "kso.app_chat.message.create,kso.app_chat.create"

# JSON 输出（适合管道和日志采集）
openevent listen --json | jq .

# 同时输出到文件
openevent listen --output events.log

# 查看 SDK 内部调试日志
openevent listen --verbose

命令参考

openevent listen [flags]
openevent version
openevent help

listen 选项：

选项	缩写	类型	默认值	说明
`--app-id`		string		应用 ID
`--app-secret`		string		应用密钥
`--events`	`-e`	string		事件类型过滤（逗号分隔，精确匹配）
`--json`		bool	false	以 NDJSON 格式输出（每行一个 JSON 对象）
`--output`	`-o`	string		同时输出到文件（create/truncate 模式）
`--verbose`	`-v`	bool	false	显示详细日志（DEBUG 级别，输出到 stderr）
`--no-color`		bool	false	禁用彩色输出
`--no-ack`		bool	false	禁用 ACK 模式（默认开启，失败时服务端重试）
`--endpoint`		string		自定义 WebSocket 端点（完整 URL）
`--base-url`		string		WebSocket 基础地址（自动拼接事件路径，适用于国际化/私有化环境）

退出码：

退出码	含义	场景
0	正常退出	Ctrl+C / SIGTERM 优雅关闭
1	凭证错误	缺少 APP_ID/APP_SECRET、认证失败
2	连接失败	重连次数耗尽、服务端不可达
3	运行时错误	文件打开失败、其他未预期错误

本地开发

项目提供 Makefile 管理构建和测试流程：

make help             # 查看所有可用目标
make build            # 构建 CLI 到 output/openevent（自动注入版本信息）
make test             # 运行全部单元测试
make test-race        # 运行测试（含竞态检测）
make test-cover       # 运行测试并生成覆盖率报告
make lint             # 代码静态分析（go vet）
make run ARGS="listen --help"  # go run 直接运行
make clean            # 清理构建产物
make install          # 安装到 $GOPATH/bin
make                  # 默认: lint + test + build

构建产物会通过 -ldflags 自动注入版本信息，openevent version 将输出：

openevent v1.0.2 (125f725, 2026-03-26T03:01:35Z)

发布新版本

发布流程完全自动化，只需推送 tag 即可触发：

# 1. 确认主分支代码就绪
git checkout main && git pull

# 2. 创建版本 tag（遵循语义化版本）
git tag v1.1.0

# 3. 推送 tag，自动触发 GitHub Actions → GoReleaser
git push origin v1.1.0

推送 tag 后自动执行的流程：

GitHub Actions 检测到 v* tag 推送，触发 .github/workflows/release.yaml
GoReleaser 自动执行：
- 交叉编译 6 个平台二进制（macOS/Linux/Windows × amd64/arm64）
- 通过 -ldflags 注入版本号、commit hash、构建时间
- macOS/Linux 打包为 .tar.gz，Windows 打包为 .zip
- 生成 checksums.txt 校验文件
- 创建 GitHub Release 页面并上传所有产物
用户即可通过 install.sh / install.ps1 / go install / 手动下载安装新版本

GoReleaser 配置位于 .goreleaser.yaml，Release workflow 位于 .github/workflows/release.yaml。

SDK 使用

安装

go get github.com/GongchuangSu/open-event-sdk-go@v1.0.1

快速开始

package main

import (
    "context"
    "log"

    openevent "github.com/GongchuangSu/open-event-sdk-go"
)

func main() {
    client := openevent.NewClient("your_app_id", "your_app_secret",
        openevent.WithEventHandlerFunc(func(ctx context.Context, e *openevent.Event) error {
            log.Printf("收到事件: event_code=%s", e.EventCode())
            log.Printf("事件数据: %s", e.Data)
            return nil
        }),
    )

    if err := client.Start(context.Background()); err != nil {
        log.Fatal(err)
    }
}

Dispatcher 分发模式

按事件编码（event_code）分别处理不同事件：

package main

import (
    "context"
    "log"

    openevent "github.com/GongchuangSu/open-event-sdk-go"
)

func main() {
    // 创建分发器
    dispatcher := openevent.NewDispatcher()

    // 注册不同事件编码的处理器
    // 事件编码 = topic.operation，如 "kso.app_chat.message.create"
    dispatcher.RegisterFunc("kso.app_chat.message.create", func(ctx context.Context, e *openevent.Event) error {
        log.Printf("处理聊天消息事件: %s", e.Data)
        return nil
    })

    dispatcher.RegisterFunc("kso.user.status.update", func(ctx context.Context, e *openevent.Event) error {
        log.Printf("处理用户状态变更事件: %s", e.Data)
        return nil
    })

    // 注册兜底处理器
    dispatcher.RegisterFallbackFunc(func(ctx context.Context, e *openevent.Event) error {
        log.Printf("未知事件: event_code=%s", e.EventCode())
        return nil
    })

    // 创建客户端
    client := openevent.NewClient("your_app_id", "your_app_secret",
        openevent.WithDispatcher(dispatcher),
    )

    if err := client.Start(context.Background()); err != nil {
        log.Fatal(err)
    }
}

类型化事件处理

目前部分事件已支持 OnV7XXX 方法，可使用链式调用注册类型化处理器，事件数据会自动解析为对应的结构体。其他事件请使用 RegisterFunc 方法处理。

已支持 OnV7XXX 方法的事件：

方法	事件编码	说明
`OnV7AppChatMessageCreate`	`kso.app_chat.message.create`	用户给应用发送消息
`OnV7AppChatCreate`	`kso.app_chat.create`	首次创建用户和机器人的会话
`OnV7AppGroupChatDelete`	`kso.xz.app.group_chat.delete`	群聊解散
`OnV7AppGroupChatMemberUserCreate`	`kso.xz.app.group_chat.member.user.create`	用户进群
`OnV7AppGroupChatMemberUserDelete`	`kso.xz.app.group_chat.member.user.delete`	用户退群
`OnV7AppGroupChatMemberRobotCreate`	`kso.xz.app.group_chat.member.robot.create`	机器人进群
`OnV7AppGroupChatMemberRobotDelete`	`kso.xz.app.group_chat.member.robot.delete`	机器人退群

组合使用示例：

package main

import (
    "context"
    "encoding/json"
    "log"

    openevent "github.com/GongchuangSu/open-event-sdk-go"
)

func main() {
    dispatcher := openevent.NewDispatcher()

    // ========== 方式一: OnV7XXX 方法（类型安全，推荐） ==========
    dispatcher.
        OnV7AppChatMessageCreate(func(ctx context.Context, e *openevent.V7AppChatMessageCreateEvent) error {
            log.Printf("收到消息: chat_id=%s, sender=%s", e.Data.Chat.Id, e.Data.Sender.Id)
            return nil
        }).
        OnV7AppChatCreate(func(ctx context.Context, e *openevent.V7AppChatCreateEvent) error {
            log.Printf("会话创建: chat_id=%s", e.Data.ChatId)
            return nil
        }).
        OnV7AppGroupChatMemberUserCreate(func(ctx context.Context, e *openevent.V7AppGroupChatMemberUserCreateEvent) error {
            log.Printf("用户进群: chat_id=%s", e.Data.ChatId)
            return nil
        })

    // ========== 方式二: RegisterFunc（处理其他事件，需自行解析 Data） ==========
    dispatcher.RegisterFunc("kso.user.status.update", func(ctx context.Context, e *openevent.Event) error {
        log.Printf("用户状态变更: %s", e.EventCode())
        var data map[string]any
        json.Unmarshal([]byte(e.Data), &data)
        log.Printf("数据: %+v", data)
        return nil
    })

    // ========== 兜底处理器 ==========
    dispatcher.RegisterFallbackFunc(func(ctx context.Context, e *openevent.Event) error {
        log.Printf("未处理的事件: %s", e.EventCode())
        return nil
    })

    client := openevent.NewClient("your_app_id", "your_app_secret",
        openevent.WithDispatcher(dispatcher),
    )

    if err := client.Start(context.Background()); err != nil {
        log.Fatal(err)
    }
}

使用事件数据模型：

如需直接使用事件数据模型，请导入 model 包：

import "github.com/GongchuangSu/open-event-sdk-go/event/model"

var sender model.V7Identity
var data model.V7NotificationAppChatMessageCreateData

配置选项

基础配置

client := openevent.NewClient(appId, appSecret,
    // 自定义 WebSocket 端点（可选，默认 wss://openapi.wps.cn/v7/event/ws）
    openevent.WithEndpoint("wss://custom-endpoint.com/event/ws"),

    // 设置日志级别
    openevent.WithLogLevel(openevent.LogLevelDebug),

    // 使用自定义日志
    openevent.WithLogger(customLogger),
)

国际化/私有化环境

使用 WithBaseUrl 设置基础地址，SDK 自动拼接事件路径并处理签名：

// 国际化环境
client := openevent.NewClient(appId, appSecret,
    openevent.WithBaseUrl("wss://ap.wps.com/openapi"),
)

// 私有化部署
client := openevent.NewClient(appId, appSecret,
    openevent.WithBaseUrl("wss://api.mycompany.internal"),
)

CLI 使用：

openevent listen --base-url wss://ap.wps.com/openapi

注意：WithBaseUrl 与 WithEndpoint 的区别：

WithBaseUrl：传入基础地址（如 wss://ap.wps.com/openapi），SDK 自动拼接 /v7/event/ws 并使用固定路径签名

WithEndpoint：传入完整 URL（如 wss://custom.com/v7/event/ws），签名使用 URL 的完整路径部分

重连配置（指数退避策略）

SDK 采用指数退避（Exponential Backoff）策略进行重连，避免在网络恢复时产生惊群效应。

重连间隔计算公式：interval = min(baseInterval * multiplier^(retryCount-1), maxInterval) * (1 ± jitter)

client := openevent.NewClient(appId, appSecret,
    // 开启/关闭自动重连（默认开启）
    openevent.WithAutoReconnect(true),

    // 重连基础间隔（默认 1 秒）
    openevent.WithReconnectBaseInterval(1 * time.Second),

    // 重连最大间隔（默认 60 秒）
    openevent.WithReconnectMaxInterval(60 * time.Second),

    // 重连间隔倍数（默认 2.0）
    openevent.WithReconnectMultiplier(2.0),

    // 最大重试次数（-1 表示无限重试，默认 -1）
    openevent.WithReconnectMaxRetry(10),

    // 重连抖动系数（默认 0.2，表示 ±20% 随机抖动）
    openevent.WithReconnectJitter(0.2),
)

默认重连时间序列示例（baseInterval=1s, multiplier=2, maxInterval=60s, jitter=0.2）：

重试次数	基础间隔	实际间隔范围
1	1s	0.8s ~ 1.2s
2	2s	1.6s ~ 2.4s
3	4s	3.2s ~ 4.8s
4	8s	6.4s ~ 9.6s
5	16s	12.8s ~ 19.2s
6	32s	25.6s ~ 38.4s
7+	60s	48s ~ 72s

超时配置

client := openevent.NewClient(appId, appSecret,
    // 写操作超时（默认 10 秒）
    openevent.WithWriteWait(10 * time.Second),

    // Pong 等待超时（默认 90 秒）
    openevent.WithPongWait(90 * time.Second),
)

事件结构

原始事件消息（加密）

SDK 接收到的原始消息包含以下字段：

字段	类型	说明
`topic`	string	消息主题（根据不同事件而定）
`operation`	string	消息变更动作（根据不同事件而定）
`time`	int64	时间（秒为单位的时间戳）
`nonce`	string	iv 向量（解密时使用）
`signature`	string	消息签名
`encrypted_data`	string	加密的消息数据

解密后的事件结构

SDK 会自动验证签名并解密数据，处理器接收到的是解密后的事件：

type Event struct {
    Topic     string `json:"topic"`      // 消息主题
    Operation string `json:"operation"`  // 变更动作
    Time      int64  `json:"time"`       // 时间戳（秒）
    Data      string `json:"data"`       // 解密后的事件数据（JSON 字符串）
}

// 获取事件编码
func (e *Event) EventCode() string

事件编码（event_code）说明：

事件编码 = topic + . + operation，全局唯一
例如：topic="kso.app_chat.message", operation="create" → event_code="kso.app_chat.message.create"
通过 e.EventCode() 方法动态获取事件编码
Dispatcher 按事件编码进行事件分发

签名验证

签名计算方式：

构建签名原文：content = access_key:topic:nonce:time:encrypted_data
计算签名：signature = HMAC-SHA256(content, secret_key)
签名使用 URL 安全的无填充 base64 编码

数据解密

解密方式：

encrypted_data 使用标准的有填充 base64 编码
密钥 cipher = MD5(secret_key)
使用 AES-CBC 模式解密，iv 为 nonce 的前 16 字节
解密后移除 PKCS7 填充

事件处理

处理成功

handler := openevent.HandlerFunc(func(ctx context.Context, e *openevent.Event) error {
    log.Printf("处理事件: event_code=%s", e.EventCode())
    
    // 解析事件数据
    var data map[string]interface{}
    if err := json.Unmarshal([]byte(e.Data), &data); err != nil {
        return err
    }
    
    // 处理业务逻辑...
    return nil
})

处理失败

返回 error 表示处理失败：

handler := openevent.HandlerFunc(func(ctx context.Context, e *openevent.Event) error {
    if err := processEvent(e); err != nil {
        return err // 处理失败
    }
    return nil
})

优雅关闭

使用 context 控制连接生命周期：

ctx, cancel := context.WithCancel(context.Background())

// 监听退出信号
go func() {
    sigChan := make(chan os.Signal, 1)
    signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
    <-sigChan

    cancel()       // 取消 context
    client.Stop()  // 停止客户端
}()

client.Start(ctx)

自定义日志

实现 Logger 接口：

type Logger interface {
    Debug(ctx context.Context, args ...interface{})
    Info(ctx context.Context, args ...interface{})
    Warn(ctx context.Context, args ...interface{})
    Error(ctx context.Context, args ...interface{})
}

示例：

type MyLogger struct{}

func (l *MyLogger) Debug(ctx context.Context, args ...interface{}) {
    // 自定义实现
}

// ... 其他方法

client := openevent.NewClient(appId, appSecret,
    openevent.WithLogger(&MyLogger{}),
)

目录结构

open-event-sdk-go/
├── Makefile                # 构建/测试/安装
├── .goreleaser.yaml        # 多平台发布配置
├── .github/workflows/      # CI/CD
│   ├── ci.yaml             # 测试 + lint（Go 1.21-1.23）
│   └── release.yaml        # tag → GoReleaser 发布
├── openevent.go            # 根包入口（推荐使用）
├── cmd/openevent/          # CLI 工具
│   ├── main.go             # 入口（版本注入点）
│   ├── cmd/                # Cobra 命令
│   │   ├── root.go         # 根命令 + 退出码
│   │   ├── listen.go       # listen 子命令
│   │   └── version.go      # version 子命令
│   └── internal/           # CLI 内部实现
│       ├── credential.go   # 凭证解析（flag → env → TTY）
│       ├── printer.go      # 事件输出（channel 序列化）
│       ├── filter.go       # 事件过滤
│       └── logger.go       # Stderr 日志
├── ws/                     # WebSocket 客户端
│   ├── client.go           # 客户端主逻辑
│   ├── option.go           # 配置选项
│   └── error.go            # 错误定义
├── event/                  # 事件处理
│   ├── dispatcher.go       # 事件分发器
│   ├── dispatcher_typed.go # OnXXX 类型化处理方法
│   ├── typed_event.go      # 类型化事件定义
│   ├── handler.go          # Handler 接口
│   ├── event.go            # 事件实体
│   └── model/              # 事件数据模型
├── core/                   # 核心公共组件
│   └── logger.go           # 日志接口
├── internal/               # 内部实现（不对外暴露）
│   ├── kso/                # KSO-1 签名和加解密
│   └── protocol/           # WebSocket 协议定义
├── scripts/                # 安装脚本
│   ├── install.sh          # macOS / Linux
│   └── install.ps1         # Windows (PowerShell)
└── examples/               # 使用示例
    ├── simple/             # 简单示例
    └── dispatcher/         # Dispatcher 模式示例

协议说明

消息类型

服务端通过 WebSocket 向客户端推送两种类型的消息：

1. 事件消息

携带加密的事件数据，SDK 会自动验签和解密。

{
    "topic": "kso.app_chat.message",
    "operation": "create",
    "time": 1704067200,
    "nonce": "b38c06ba3330d2a3",
    "signature": "EzpccL5eAnDbOH2qtZK3fHNBaO0UV3xvYvhbWLp1wuQ",
    "encrypted_data": "oadgi2+nWGZal2EfCSlxbLrr2Aog..."
}

2. 关闭通知（goaway）

服务端主动关闭连接时发送，包含 type: "goaway" 和关闭原因：

{
    "type": "goaway",
    "reason": "server_shutdown",
    "message": "服务器维护中",
    "reconnect_ms": 5000
}

GoAway 原因类型：

原因	说明	是否重连
`server_shutdown`	服务器关闭（如维护升级）	是，按 `reconnect_ms` 延迟重连
`connection_replaced`	连接被新连接替换（同一应用重复连接）	否
`heartbeat_timeout`	心跳超时	是

心跳机制

服务端每 30 秒发送 WebSocket Ping
客户端自动回复 Pong
90 秒内未收到 Pong 则断开连接

认证方式

使用 KSO-1 签名认证，需要在 WebSocket 握手时携带以下 HTTP 头：

X-Kso-Date: 请求时间（RFC1123 格式）
X-Kso-Authorization: 签名（格式：KSO-1 {app_id}:{signature}）

许可证

MIT License

Documentation ¶

Overview ¶

Package openevent 提供事件订阅 SDK

该 SDK 用于接收和处理来自开放平台的事件推送。

快速开始:

client := openevent.NewClient("app_id", "app_secret",
    openevent.WithEventHandlerFunc(func(ctx context.Context, e *openevent.Event) error {
        log.Printf("收到事件: %s", e.EventCode())
        return nil
    }),
)
client.Start(context.Background())

使用 Dispatcher 分发事件:

dispatcher := openevent.NewDispatcher().
    // 已支持的事件使用 OnV7XXX 方法（类型安全）
    OnV7AppChatMessageCreate(func(ctx context.Context, e *openevent.V7AppChatMessageCreateEvent) error {
        log.Printf("收到消息: %s", e.Data.Message.Id)
        return nil
    })

// 其他事件使用 RegisterFunc 方法
dispatcher.RegisterFunc("kso.other.event", func(ctx context.Context, e *openevent.Event) error {
    log.Printf("其他事件: %s", e.Data)
    return nil
})

client := openevent.NewClient("app_id", "app_secret",
    openevent.WithDispatcher(dispatcher),
)

Constants ¶

View Source

const (
	// LogLevelDebug 调试级别
	LogLevelDebug = core.LogLevelDebug

	// LogLevelInfo 信息级别
	LogLevelInfo = core.LogLevelInfo

	// LogLevelWarn 警告级别
	LogLevelWarn = core.LogLevelWarn

	// LogLevelError 错误级别
	LogLevelError = core.LogLevelError
)

Variables ¶

View Source

var (
	// ErrHandlerNotSet 事件处理器未设置
	ErrHandlerNotSet = ws.ErrHandlerNotSet

	// ErrClientClosed 客户端已关闭
	ErrClientClosed = ws.ErrClientClosed

	// ErrReconnectExceeded 超过最大重连次数
	ErrReconnectExceeded = ws.ErrReconnectExceeded
)

View Source

var NewClient = ws.NewClient

NewClient 创建 WebSocket 客户端

参数:

appId: 应用 ID
appSecret: 应用密钥
opts: 可选配置项

View Source

var NewDefaultLogger = core.NewDefaultLogger

NewDefaultLogger 创建默认日志实例

View Source

var NewDispatcher = event.NewDispatcher

NewDispatcher 创建事件分发器

View Source

var NewNopLogger = core.NewNopLogger

NewNopLogger 创建空日志实例（不输出任何日志）

View Source

var WithAckMode = ws.WithAckMode

WithAckMode 设置是否启用 ACK 模式（默认: true）启用后，事件处理结果会发送给服务端，处理失败时服务端会触发重试

View Source

var WithAutoReconnect = ws.WithAutoReconnect

WithAutoReconnect 设置是否开启自动重连（默认: true）

View Source

var WithBaseUrl = ws.WithBaseUrl

WithBaseUrl 设置 WebSocket 基础地址 SDK 会自动拼接事件路径（/v7/event/ws），签名始终使用固定事件路径适用于国际化环境或私有化部署，域名不同但事件路径固定的场景

View Source

var WithDispatcher = ws.WithDispatcher

WithDispatcher 设置事件分发器

View Source

var WithEndpoint = ws.WithEndpoint

WithEndpoint 设置 WebSocket 连接端点（完整 URL）默认使用 SDK 内置端点，一般无需设置

View Source

var WithEventHandler = ws.WithEventHandler

WithEventHandler 设置单一事件处理器

View Source

var WithEventHandlerFunc = ws.WithEventHandlerFunc

WithEventHandlerFunc 设置函数类型的事件处理器

View Source

var WithLogLevel = ws.WithLogLevel

WithLogLevel 设置日志级别

View Source

var WithLogger = ws.WithLogger

WithLogger 设置自定义日志实例

View Source

var WithPongWait = ws.WithPongWait

WithPongWait 设置等待 Pong 响应超时时间（默认: 90秒）

View Source

var WithReconnectBaseInterval = ws.WithReconnectBaseInterval

WithReconnectBaseInterval 设置重连基础间隔（默认: 1秒）

View Source

var WithReconnectJitter = ws.WithReconnectJitter

WithReconnectJitter 设置重连抖动系数（默认: 0.2）

View Source

var WithReconnectMaxInterval = ws.WithReconnectMaxInterval

WithReconnectMaxInterval 设置重连最大间隔（默认: 60秒）

View Source

var WithReconnectMaxRetry = ws.WithReconnectMaxRetry

WithReconnectMaxRetry 设置最大重试次数（默认: -1 无限重试）

View Source

var WithReconnectMultiplier = ws.WithReconnectMultiplier

WithReconnectMultiplier 设置重连间隔倍数（默认: 2.0）

View Source

var WithWriteWait = ws.WithWriteWait

WithWriteWait 设置写操作超时时间（默认: 10秒）

Functions ¶

This section is empty.

Types ¶

type Client ¶

type Client = ws.Client

Client WebSocket 长连接客户端

type ClientError ¶

type ClientError = ws.ClientError

ClientError 客户端错误

type Dispatcher ¶

type Dispatcher = event.Dispatcher

Dispatcher 事件分发器

type Event ¶

type Event = event.Event

Event 事件实体

type Handler ¶

type Handler = event.Handler

Handler 事件处理器接口

type HandlerFunc ¶

type HandlerFunc = event.HandlerFunc

HandlerFunc 函数类型的事件处理器

type LogLevel ¶

type LogLevel = core.LogLevel

LogLevel 日志级别

type Logger ¶

type Logger = core.Logger

Logger 日志接口

type Option ¶

type Option = ws.Option

Option 客户端配置选项

type ServerError ¶

type ServerError = ws.ServerError

ServerError 服务端错误

type V7AppChatCreateEvent ¶ added in v1.0.1

type V7AppChatCreateEvent = event.V7AppChatCreateEvent

V7AppChatCreateEvent 应用会话创建事件

type V7AppChatMessageCreateEvent ¶ added in v1.0.1

type V7AppChatMessageCreateEvent = event.V7AppChatMessageCreateEvent

V7AppChatMessageCreateEvent 应用收到消息事件

type V7AppGroupChatDeleteEvent ¶ added in v1.0.1

type V7AppGroupChatDeleteEvent = event.V7AppGroupChatDeleteEvent

V7AppGroupChatDeleteEvent 群聊解散事件

type V7AppGroupChatMemberRobotCreateEvent ¶ added in v1.0.1

type V7AppGroupChatMemberRobotCreateEvent = event.V7AppGroupChatMemberRobotCreateEvent

V7AppGroupChatMemberRobotCreateEvent 机器人进群事件

type V7AppGroupChatMemberRobotDeleteEvent ¶ added in v1.0.1

type V7AppGroupChatMemberRobotDeleteEvent = event.V7AppGroupChatMemberRobotDeleteEvent

V7AppGroupChatMemberRobotDeleteEvent 机器人退群事件

type V7AppGroupChatMemberUserCreateEvent ¶ added in v1.0.1

type V7AppGroupChatMemberUserCreateEvent = event.V7AppGroupChatMemberUserCreateEvent

V7AppGroupChatMemberUserCreateEvent 用户进群事件

type V7AppGroupChatMemberUserDeleteEvent ¶ added in v1.0.1

type V7AppGroupChatMemberUserDeleteEvent = event.V7AppGroupChatMemberUserDeleteEvent

V7AppGroupChatMemberUserDeleteEvent 用户退群事件

Source Files ¶

View all Source files

openevent.go

Directories ¶

Path	Synopsis
cmd
openevent command
openevent/cmd
openevent/internal
core Package core 提供 SDK 的核心公共组件	Package core 提供 SDK 的核心公共组件
event Package event 提供事件处理相关的类型和接口	Package event 提供事件处理相关的类型和接口
model Package model 定义事件数据模型该包中的类型定义可通过代码生成器自动生成类型命名与 xidl 定义保持一致，使用 V7 前缀	Package model 定义事件数据模型该包中的类型定义可通过代码生成器自动生成类型命名与 xidl 定义保持一致，使用 V7 前缀
examples
dispatcher command Package main 演示使用 Dispatcher 处理事件	Package main 演示使用 Dispatcher 处理事件
simple command Package main 演示使用单一 Handler 接收和处理事件	Package main 演示使用单一 Handler 接收和处理事件
internal
kso Package kso 提供 KSO-1 签名相关工具（内部使用）	Package kso 提供 KSO-1 签名相关工具（内部使用）
protocol Package protocol 定义 WebSocket 协议常量（内部使用）	Package protocol 定义 WebSocket 协议常量（内部使用）
ws Package ws 提供 WebSocket 长连接客户端	Package ws 提供 WebSocket 长连接客户端

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

README ¶

open-event-sdk-go

特性

CLI 工具 (openevent)

安装

使用

命令参考

本地开发

发布新版本

SDK 使用

安装

快速开始

Dispatcher 分发模式

类型化事件处理

配置选项

基础配置

国际化/私有化环境

重连配置（指数退避策略）

超时配置

事件结构

原始事件消息（加密）

解密后的事件结构

签名验证

数据解密

事件处理

处理成功

处理失败

优雅关闭

自定义日志

目录结构

协议说明

消息类型

1. 事件消息

2. 关闭通知（goaway）

心跳机制

认证方式

许可证

Documentation ¶

Overview ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

Types ¶

type Client ¶

type ClientError ¶

type Dispatcher ¶

type Event ¶

type Handler ¶

type HandlerFunc ¶

type LogLevel ¶

type Logger ¶

type Option ¶

type ServerError ¶

type V7AppChatCreateEvent ¶ added in v1.0.1

type V7AppChatMessageCreateEvent ¶ added in v1.0.1

type V7AppGroupChatDeleteEvent ¶ added in v1.0.1

type V7AppGroupChatMemberRobotCreateEvent ¶ added in v1.0.1

type V7AppGroupChatMemberRobotDeleteEvent ¶ added in v1.0.1

type V7AppGroupChatMemberUserCreateEvent ¶ added in v1.0.1

type V7AppGroupChatMemberUserDeleteEvent ¶ added in v1.0.1

Source Files ¶

Directories ¶