wsbus

package

v0.0.0-...-99b6fc9 Latest Latest Go to latest Published: Sep 12, 2022 License: MIT Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ClientMap = make(map[string]*WsClient)

func ReceiveMessage(ctx context.Context, conn *websocket.Conn)

func SendGroupMessage(ctx context.Context, sourceId, targetId uint64, message string) error

func SendUserMessage(ctx *ctx.Ctx, sourceId, targetId uint64, message string, datetime time.Time) error

SendUserMessage 发送一对一的消息，先把消息保存到数据库，然后直接通过websocket发送。

如果消息发送失败，也不返回error，保证对方在离线状态下依然可用

msg_time: 如果消息时间是今天，那么不发送日期，如果消息时间不是今天，那么包含日期

type WsClient struct {
	Conn    *websocket.Conn
	MsgChan chan *WsMessage
}

type WsMessage struct {
	Message  string
	SourceId uint64
	TargetId uint64
}