Go语言实现一个简单的并发聊天室的项目实战
作者:Sirius_7 发布时间:2024-02-15 03:40:33
标签:Go语言,并发聊天室
写在前面
Go语言在很多方面天然的具备很多便捷性,譬如网络编程,并发编程。而通道则又是Go语言实现并发编程的重要工具,因为其承担着通道之间互相通信的重任。并且因为其本身就是并发安全的,所以在某些场景下是非常好用的。
并发聊天服务器
这里主要是实现一个简单的并发聊天服务器。首先,客户端可以在服务器中注册自己的信息(登录以及退出),客户端发出的所有的信息由服务器向各个客户端进行转发,或者换句话说是广播。
具体代码
服务端
说的再多,没有代码简单明了,直接上代码~
package main
import (
"bufio"
"fmt"
"log"
"net"
)
type client chan <- string //定义一个单向的向外发送数据的通道
var (
entering = make(chan client)
leaving = make(chan client)
messages = make(chan string)
)
func main() {
listener, err := net.Listen("tcp","localhost:8000")
if err != nil {
log.Fatal("network is broken", err)
}
go broadcaster()
for {
conn, err := listener.Accept()
if err != nil {
log.Print(err)
continue
}
go handleConn1(conn)
}
}
func broadcaster() {
clients := make(map[client]bool) //存储每个client的登录状态
for{
select {
case msg := <-messages:
for cli := range clients {
cli <- msg
}
case cli := <-entering:
clients[cli] = true
case cli := <-leaving:
delete(clients,cli)
close(cli)
}
}
}
func handleConn1(conn net.Conn) {
ch := make(chan string)
go clientWriter(conn, ch)
who := conn.RemoteAddr().String()
ch <- "You are " + who
entering <- ch
messages <- who + "has arrived"
input := bufio.NewScanner(conn)
for input.Scan() {
messages <- who + ":" + input.Text()
}
leaving <- ch
messages <- who + "has left"
conn.Close()
}
func clientWriter(conn net.Conn, ch <- chan string) {
for msg := range ch {
fmt.Fprintln(conn, msg)
}
}
客户端
客户端相对简单,只是涉及到信息的发送和接受工作。
package main
import (
"io"
"log"
"net"
"os"
)
func main() {
conn, err := net.Dial("tcp","localhost:8000")
if err != nil {
log.Fatal("Connected has been refused!",err)
}
defer conn.Close()
go mesCopy(os.Stdout,conn)
mesCopy(conn,os.Stdin)
}
func mesCopy(des io.Writer, res io.Reader) {
if _, err := io.Copy(des, res); err != nil {
log.Print("wrong!")
}
}
总结
实现原理较为简单,所以代码并没有多少注释,如果有任何疑问,欢迎留言讨论。最后说一句,在MIT的课程中,其实并不是很推荐在并发编程中使用通道chan,除非你对其应用的场景和可能出现的情况有很好的把握,不然可能会出现很多不可预测的事情,譬如死锁(见另外一篇博客)。在这种时候,共享变量将会是一种很好的选择,具体查看go多线程实践。
来源:https://blog.csdn.net/weixin_38107316/article/details/116161658
0
投稿
猜你喜欢
- 在SQL Server数据库管理中,针对分析服务Analysis Services 的性能优化必不可少,这里我们将学习到使用DMV来进行An
- /** * The maximum supported {@code LocalTime}, '23:59:59.999999999
- 1 以下代码的输出结果为:print(round(-3.6))A.-4B.-4.0C.-3D. -3.02 以下代码的输出结果为(Pytho
- 您是否知道 OpenCV 具有执行行人检测的内置方法?OpenCV 附带一个预训练的 HOG + 线性 SVM 模型,可用于在图像和视频流中
- 一空间多域名绑定3种方法,HTML代码格式:<html> <script language=javascript
- 新建图像文件后选Channels面板,新建Alpha1通道; 做压
- 本文实例讲述了php+js实现的无刷新下载文件功能。分享给大家供大家参考,具体如下:服务器端页面步骤就是,设置头文件参数,然后读入并输出文件
- Python爬虫可以爬取的东西有很多,Python爬虫怎么学?简单的分析下:如果你仔细观察,就不难发现,懂爬虫、学习爬虫的人越来越多,一方面
- Python入门 本系列为Python学习相关笔记整理所得,IT人
- 在开发过程中经常碰到在本地环境无法完成联调测试的情况,必须到统一的联机环境对接其他系统测试。往往是出现了BUG难以查找数据记录及时定位到错误
- 获取带有中文参数的url内容对于中文的参数如果不进行编码的话,python的urllib2直接处理会报错,我们可以先将中文转换成utf- 8
- <style type="text/css"> <!-- body,td,th {
- 调用时输入参数如: www.jb51.net/表示删除www.jb51.net首页的缓存, www.jb51.net/test.
- <?php/** * HOST: www.icbase.com *///set_time_limit(0);//
- 项目我采用了三层结构,我把LINQ的映射文件放到了DAL这个层中,映射文件自动由VS2008生成,在原来的机器上一直正常,一点问题都没有,当
- 前言运用pandas 库对所得到的数据进行数据清洗,复习一下相关的知识。1 数据清洗1.1 处理缺失数据对于数值型数据,分为缺失值(NAN)
- 见下:<form action="./calculation.asp"><input&nbs
- 学习任何一门语言都是从入门(1年左右),通过不间断练习达到熟练水准(3到5年),少数人最终能精通语言,成为执牛耳者,他们是金字塔的最顶层。虽
- 在python中,用于数组拼接的主要来自numpy包,当然pandas包也可以完成。而,numpy中可以使用append和concatena
- jQuery 1.4 源码 449 行(core.js 431 行),判断是否为函数的方法如下(思路来源于 Douglas Crockfor