wechat-api/internal/pkg/wechat_ws/test/main.go

package main

import (
	"github.com/zeromicro/go-zero/core/logx"
	"net/url"
	"wechat-api/internal/pkg/wechat_ws"
)

func msgHandler(msg wechat_ws.MsgJsonObject) error {
	logx.Info("当前处理的消息是：", msg)
	return nil
}

func main() {
	u := url.URL{Scheme: "ws", Host: "chat.gkscrm.com:13088"}

	logx.Info(u.String())

	client, err := wechat_ws.NewWechatWsClient(u.String(), "default")
	if err != nil {
		return
	}

	go client.WritePump()

	//client.SendMsg([]byte(`{"msgType":"text","message":"你好"}`))
	//
	//time.Sleep(5)
	//
	//client.SendMsg([]byte(`{"msgType":"text","message":"二次你好"}`))

	client.ReadPump(msgHandler)
}