public class APIDemo { static { // 事件回调 McBotEvents.ON_CHAT.register((player, msgId, msg) -> System.out.printf("McBot刚刚转发一条消息。由%s发送了%s (%s)%n", player.getName().getString(), msg, msgId)); } /**  * 群里发送消息  * @param groupId 群号  * @param message 消息  */ public static void doSend(long groupId, String message) throws CommandSyntaxException { Const.sendGroupMsg(groupId, message) } /**  * 撤回消息  * @param message_id 消息ID  */ public static void recallMessage(int message_id) { JsonObject json = new Gson().fromJson( String.format("{'message_id': %s}", message_id), JsonObject.class); Const.customRequest(ActionType.DELETE_MSG, json); } }

public class WebSocketServerTest { public static void main(String[] args) throws Exception { public static LinkedBlockingQueue<String> blockingQueue = new LinkedBlockingQueue<>();//使用队列传输数据 public static Thread app = new Thread(() -> { service = new ConnectFactory(new BotConfig(), blockingQueue);//创建websocket连接 bot = service.ws.createBot();//创建机器人实例 }, "BotServer"); app.start(); EventBus bus = new EventBus(blockingQueue);//创建事件分发器 GroupMessageListener groupMessageListener = new GroupMessageListener(); groupMessageListener.addHandler("天气", new Handler<GroupMessageEvent>() { @Override public void handle(GroupMessageEvent groupMessage) { System.out.println(groupMessage); } }); bus.addListener(groupMessageListener);//加入监听 bus.addListener(new SimpleListener<PrivateMessageEvent>() {//私聊监听 @Override public void onMessage(PrivateMessageEvent privateMessage) { System.out.println(privateMessage); } }); } }