使用标准库

implementation("love.forte.simbot.component:simbot-component-kook-stdlib:4.0.0-beta4")

implementation 'love.forte.simbot.component:simbot-component-kook-stdlib:4.0.0-beta4'

<dependency> <groupId>love.forte.simbot.component</groupId> <!-- Maven 需要添加 `-jvm` 后缀来选择使用 JVM 平台 --> <artifactId>simbot-component-kook-stdlib-jvm</artifactId> <version>4.0.0-beta4</version> </dependency>

// 准备 bot 的必要信息 val clientId = "xxxx" val token = "xxxx" // 用于注册 bot 的 “票据” 信息。 val ticket = Ticket.botWsTicket(clientId, token) // 构建一个 Bot，并可选的进行一些配置。 val bot = BotFactory.create(ticket) { // 比如禁用API请求的超时时长限制 disableTimeout() // 一些其他的配置... } // 注册事件有一些不同但类似的方式 // 1️⃣ 通过 subscribe 注册一个普通的事件处理器，此处理器会接收并处理所有类型的事件 // subscribe 是最基本的注册方式，也是其他方式的最终汇集点 bot.subscribe { raw -> // raw 代表事件的原始JSON字符串 // this: Event<*>, 也就是解析出来的事件结构体 println("event: $this") println("event.extra: $extra") println("raw: $raw") } // 2️⃣ 通过 subscribe<EventExtraType> 注册一个针对具体 Event<EventExtra> 事件类型的事件处理器， // 它只有在接收到的 Event.extra 与目标类型一致时才会处理。 // 此示例展示处理 KMarkdownEventExtra 也就 KMarkdown 类型的消息事件， // 并在对方发送了包含 'stop' 的文本时终止 bot。 bot.subscribe<KMarkdownEventExtra> { // raw 代表事件的原始JSON字符串 // this: Event<KMarkdownEventExtra>, 也就是解析出来的事件结构体， // 并且 extra 类型为指定的 KMarkdownEventExtra println("event kmarkdown: ${extra.kmarkdown}") if ("stop" in extra.kmarkdown.rawContent) { // 终止 bot bot.cancel() } } // 启动 bot, 此时会开始获取ws、连接并接收消息。 bot.start() // 挂起 bot，直到它结束（被终止） bot.join()

// 准备 bot 的必要信息 var clientId = "xxxx"; var token = "xxxx"; // 用于注册 bot 的 “票据” 信息。 var ticket = Ticket.botWsTicket(clientId, token); // 构建一个 Bot，并可选的进行一些配置。 Bot bot = BotFactory.create(ticket, config -> { // 各种配置... // 比如禁用API请求的超时时长限制 config.disableTimeout(); // 一些其他的配置... }); // 通过 subscribe 注册一个普通的事件处理器， // 此处理器会接收并处理所有类型的事件 bot.subscribe(EventProcessors.async((event, raw) -> { // raw 代表事件的原始JSON字符串 // event: Event<*>, 也就是解析出来的事件结构体 System.out.println("event: " + event); System.out.println("event.extra: " + event.getExtra()); System.out.println("raw: " + raw); // 异步处理器必须返回 CompletableFuture return CompletableFuture.completedFuture(null); })); // 通过 subscribe 注册一个普通的事件处理器， // 此处理器会接收并处理指定的类型 AtMessageCreate 的事件 // 此示例展示处理 AtMessageCreate 也就公域是消息事件，并在对方发送了包含 'stop' 的文本时终止 bot。 bot.subscribe(EventProcessors.async(KMarkdownEventExtra.class, (event, raw) -> { // raw 代表事件的原始JSON字符串 // event: Event<? extends KMarkdownEventExtra>, 也就是解析出来的事件结构体 System.out.println("event kmarkdown: " + event.getExtra().getKmarkdown()); if (event.getExtra().getKmarkdown().getRawContent().contains("stop")) { // 终止 bot bot.close(); } // 异步处理器必须返回 CompletableFuture return CompletableFuture.completedFuture(null); })); // 异步地启动bot，并在 bot 启动完成后， // 将 bot 转化为 future，这个 future 会在 bot 被终止时完成 // 其实也可以把 startAsync 和 asFuture 拆开写，效果相同。 var future = bot.startAsync() .thenCompose(unit -> bot.asFuture()); // 阻塞当前线程，直到 bot 被终止。 future.join();

// 准备 bot 的必要信息 var clientId = "xxxx"; var token = "xxxx"; // 用于注册 bot 的 “票据” 信息。 var ticket = Ticket.botWsTicket(clientId, token); // 构建一个 Bot，并可选的进行一些配置。 Bot bot = BotFactory.create(ticket, config -> { // 各种配置... // 比如禁用API请求的超时时长限制 config.disableTimeout(); // 一些其他的配置... }); // 通过 subscribe 注册一个普通的事件处理器， // 此处理器会接收并处理所有类型的事件 bot.subscribe(EventProcessors.async((event, raw) -> { // raw 代表事件的原始JSON字符串 // event: Event<*>, 也就是解析出来的事件结构体 System.out.println("event: " + event); System.out.println("event.extra: " + event.getExtra()); System.out.println("raw: " + raw); })); // 通过 subscribe 注册一个普通的事件处理器， // 此处理器会接收并处理指定的类型 AtMessageCreate 的事件 // 此示例展示处理 AtMessageCreate 也就公域是消息事件，并在对方发送了包含 'stop' 的文本时终止 bot。 bot.subscribe(EventProcessors.block(KMarkdownEventExtra.class, (event, raw) -> { // raw 代表事件的原始JSON字符串 // event: Event<? extends KMarkdownEventExtra>, 也就是解析出来的事件结构体 System.out.println("event kmarkdown: " + event.getExtra().getKmarkdown()); if (event.getExtra().getKmarkdown().getRawContent().contains("stop")) { // 终止 bot bot.close(); } })); // 启动bot bot.startBlocking(); // 阻塞当前线程，直到 bot 被终止。 bot.joinBlocking();