GO------小白之并发聊天室
因为没有写客户端、可以在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
}
}
}
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
excel导入工具
1 介绍 excel导入工具 整个项目的代码结构如下 \---excelExport # 导出工具包 | AsyncExportExcel.java #多线程导出 | ExcelImport.java # 导出工具类 | +---data | BaseParam.java # 基础导出参数类 | +---dataConversion | DataExportConversion.java # 属性导出转换接口 | +---defaultDataHandle # 默认的数据处理 | AbstractDataHandler.java | BooleanDataHandler.java | DataHandlerFactory.java | DateDataHandler.java | StringDataHandler.java | \---style # 默认的样式 AbstractCellStyle.java DefaultDataCellStyle.java DefaultTitleCellStyle.java com \---utils +---demo # 案例相关 | | Ex...
- 下一篇
AR研究-Demo集
原文: AR研究-Demo集 之前研究了图像处理、图像识别及AR 等相关技术,下载了很多开源源码进行学习和尝试引用,包括c++、c#、Opengl、Emgu、 Aforge、OpenCV、QRCode、Zxing等相关的很多资料,有些源码下载下来并不能运行,尝试修复了一些Bug使的源码能够运行起来。 但是写这篇文章的时候,研究学习时的思路或者碰的壁,已经忘得差不多了。工作繁忙,没有把研究过程完整的记录下来是种遗憾。 若有需要的请去github 搜索 DuelCode。 部分研究效果图如下:
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- CentOS关闭SELinux安全模块
- Hadoop3单机部署,实现最简伪集群
- CentOS6,7,8上安装Nginx,支持https2.0的开启
- SpringBoot2全家桶,快速入门学习开发网站教程
- SpringBoot2更换Tomcat为Jetty,小型站点的福音
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8,CentOS7,CentOS6编译安装Redis5.0.7
- MySQL8.0.19开启GTID主从同步CentOS8
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2整合Redis,开启缓存,提高访问速度