• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

GO------小白之并发聊天室

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

因为没有写客户端、可以在cmd中利用  nc -u 来充当客户端

广播用户上线:

                      1、主go程中创建socket、defer

                      2、循环监听客户端连接请求

                      3、有一个客户端链接、创建新go程处理客户数据

                      4、组织用户相关信息、全局变量(结构体、map、channel)

                      5、Hadlconn、初始化新用户结构体信息、获取客户端IP和port、初始化新用户结构体信息、 name==addr

                      6、创建manager管理go程、要在for循环accpet之前、实现manager、初始化在线用户map.循环读取全局的channel、如果无数据阻塞、如果有数据遍历在线用户                                map、将数据写到用户的channel中

                      7、新用户添加到map中、key==ip+port  value==结构体

                      8、创建WriteToClient go程专门给当前用户发送消息、遍历自带C、读数据、Conn.Write写到客户端

                      9、Hadlconn中。结束位置、组织用户上线信息、将用户上线信息写到全局channel--Maneger被*** 

                      10、Hadlconn结尾处要有for循环、不然直接终止


有问题的地方都已经注释


接下来要在基础框架上增加小功能

发送消息内容:

                       1、封装函数来广播用户传的消息,传到massage中

                       2、起匿名go程、主要是来读取客户端发送的内容、写到全局massage中

                       3、for 循环读取客户端发送的内容

                       4、写给全局massage

查询在线用户:

                       将buf里减去一个“\n”

                        判断是否为who,如果为who、遍历map ,将名字利用conn.Write写到当前客户端

修改用户名:

                    1、将读取到的masg进行判断是否为rename

                    2、提取rename| 后的字符串、存入到client.name成员中

                    3、更新在线用户列表  onlinemap--key-----ip+port

                    4、提示用户更新成功

用户退出:

                    1、在用户登录成功后、创建监听用户退出的channel---isQuit

                    2、当conn.read==0时、isQuit<-true

                    3、在handleConnect结尾for中、添加select监听<-isQuit

                    4、条件满足、将用户从在线列表移除、阻止用户下线消息、写入massage通道

超时强踢:

                    1、在select中添加监听定时器time.After,计时到达将用户从在线列表移除、阻止用户下线消息、写入                             massage通道

                    2、判断用户是否活跃,创建监听活跃的channel、只要用户执行聊天改名查询任意操作,向此channel                             写数据

                    3、在select添加用户活跃度的监听、条件满足、不作为,目的是重置上面创建的计时器


这些功能其实都是在HandleConn函数中实现的

Func HandleConn(connnet.Conn){

defer conn.Close()

//初始化结构体

addr:=conn.RemoteAddr().String()

client:=Client{make(chanstring),addr,addr}

Olinemap[addr]=client

msg:=Mkmas(client,"login")

//将消息传到全局通道发送给其他人

goWriteToClient(client,conn)

Massage<-msg

quit:=make(chanbool)

datahas:=make(chanbool)

//匿名函数主要做的是客户端写入的数据

buf:=make([]byte,1024)

go func() {

for{

n,err:=conn.Read(buf)

ifn==0{

quit<-true

fmt.Println("客户端退出")

return

}

iferr!=nil{

fmt.Println("conn.Read error",err)

return

}

msg:=string(buf[:n-1])

ifmsg=="who"&&len(msg)==3{

conn.Write([]byte("user list:"))

for_,value:=rangeOlinemap{

Massage<-value.Addr+value.Name

}

}else iflen(msg)>=8&&msg[:6]=="rename"{

newname:=msg[7:]

client.Name=newname

Olinemap[addr]=client         Olinemap[addr].Name=msg[7:,go语言里不支持这样修改结构体中的数据

conn.Write([]byte("rename successfully"))

}else{

info:=Mkmas(client,msg)

Massage<-info

}

datahas<-true                //注意位置、如果客户端改名、who命令都算活跃

}

}()

for{

select{

case<-quit:            //确定退出、n==0时

close(client.C)        //关闭WriteToClient函数

delete(Olinemap,addr)

str:=Mkmas(client,"exit")

fmt.Println(str,"exit")

Massage<-str

return                //return当前go程返回、但是中间创建的go程不会停止。所以要将WriteToClient关闭

case<-datahas:       //如果客户端活跃则不做操作,这个是为了让下面的超时退出重置

case<-time.After(time.Second*10):

delete(Olinemap,addr)

str:=Mkmas(client,"timeout")

Massage<-str

fmt.Println(str,"timeout")

return

}

}

}


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
go 学习 (二):基本语法发布时间:2022-07-10
下一篇:
安装go和beego后的环境变量设置发布时间:2022-07-10
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap