Service

Documentation

Index

• Variables
• func Addmember(c *gin.Context)
• func BroadCast(username string, msg string)
• func Chat(user *User, username string, msg string)
• func ChatHandle(c *gin.Context)
• func CreateGroup(c *gin.Context)
• func DeleteMemeber(c *gin.Context)
• func Exit(c *gin.Context)
• func FindHistoryMessage(c *gin.Context)
• func GroupChat(user *User, groupName string, msg string)
• func ListenMessage()
• func Login(c *gin.Context)
• func OutLine(username string)
• func Register(c *gin.Context)
• func StoreMessageInMysql()
• func UserList(user *User)
• type User
  • func NewUser(username string, conn *websocket.Conn) *User
  • func (this *User) ListenMessage()

Variables

var Message = make(chan string)

var MysqlMessage = make(chan *Model.Message, 100)

var OnlineMap = make(map[string]*websocket.Conn)

创建一个全局的连接映射，用于存储每个用户对应的 WebSocket 连接

Functions

func Addmember

func Addmember(c *gin.Context)

func BroadCast

func BroadCast(username string, msg string)

func Chat

func Chat(user *User, username string, msg string)

func ChatHandle

func ChatHandle(c *gin.Context)

func CreateGroup

func CreateGroup(c *gin.Context)

func DeleteMemeber

func DeleteMemeber(c *gin.Context)

func Exit

func Exit(c *gin.Context)

func FindHistoryMessage

func FindHistoryMessage(c *gin.Context)

func GroupChat

func GroupChat(user *User, groupName string, msg string)

func ListenMessage

func ListenMessage()

func Login

func Login(c *gin.Context)

func OutLine

func OutLine(username string)

func Register

func Register(c *gin.Context)

func StoreMessageInMysql

func StoreMessageInMysql()

func UserList

func UserList(user *User)

Types

type User

type User struct {
	Username string
	Conn     *websocket.Conn
}

func NewUser

func NewUser(username string, conn *websocket.Conn) *User

func (*User) ListenMessage

func (this *User) ListenMessage()