基於CQHTTP插件的反向WebSocket通道提供服務端SDK層級的封裝
usingcqhttp.WebSocketReverse.NETCore;usingSystem;usingSystem.Diagnostics;usingSystem.Threading.Tasks;WebSocketServerwss=newWebSocketServer("ws://0.0.0.0:8889");CqHttpParseparse=newCqHttpParse(CqHttpApi.SetResult);CqHttpApi.Timeout=TimeSpan.FromSeconds(10);wss.OnAuthorizationAsync+=async(s,e)=>{awaitTask.Run(()=>{Debug.WriteLine(e.Connection.WebSocketConnectionInfo.ClientIpAddress);e.Allow();});};wss.OnReceiveMessageAsync+=async(s,e)=>{awaitparse.Parse(s,e);};parse.OnPrivateMessageAsync+=async(n,b)=>{varvipinfo=awaitb.Source.GetVipInfo();if(vipinfo?.VipLevel=="普通用户"){awaitb.Source.Reply(b.Message);}else{longqqId=123456789;intmessageId=awaitb.Source.SendPrivateMessage($"{b.Sender.NickName}對你說:{b.Message}",qqId);if(messageId>0)awaitb.Source.Reply("已傳達消息");}};