Go语言实现一个简单的并发聊天室的项目实战
作者:Sirius_7 时间:2024-02-15 03:40:33
写在前面
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
标签:Go语言,并发聊天室
![](/images/zang.png)
![](/images/jiucuo.png)
猜你喜欢
css清除浮动的方法总结与选择
2008-06-06 12:58:00
python爬虫开发之PyQuery模块详细使用方法与实例全解
2021-05-28 20:54:29
查找python项目依赖并生成requirements.txt的方法
2021-11-27 20:41:43
浅谈python新式类和旧式类区别
2023-03-16 16:47:37
浅析Python中的getattr(),setattr(),delattr(),hasattr()
2022-11-10 08:26:41
深入理解typescript中的infer关键字的使用
2023-10-13 19:19:33
科学与艺术兼顾的有效网页视觉设计
2007-09-18 18:03:00
![](https://img.aspxhome.com/file/uploadpic/20079/18/200791818916873.jpg)
详解使用Selenium爬取豆瓣电影前100的爱情片相关信息
2021-12-04 10:52:23
![](https://img.aspxhome.com/file/2023/3/115043_0s.jpg)
Python中np.random.randint()参数详解及用法实例
2022-04-17 19:40:48
![](https://img.aspxhome.com/file/2023/5/92375_0s.jpg)
在图片上显示左右箭头类似翻页的代码
2024-04-19 09:48:20
Python pip更新的两种方式详解
2022-07-06 20:00:29
![](https://img.aspxhome.com/file/2023/2/124372_0s.jpg)
使用 TRUNCATE TABLE 删除所有行
2008-04-24 19:20:00
如何在MySQL查询结果集中得到记录行号
2008-12-17 15:00:00
Go中string与[]byte高效互转的方法实例
2024-02-01 11:11:35
![](https://img.aspxhome.com/file/2023/8/103068_0s.jpg)
OpenCV中resize函数插值算法的实现过程(五种)
2021-07-09 21:05:24
![](https://img.aspxhome.com/file/2023/5/93815_0s.png)
基于python实现蓝牙通信代码实例
2021-08-20 07:54:06
python 列表推导式使用详解
2021-10-13 01:53:28
python glom模块的使用简介
2021-08-21 10:22:02
MySQL 错误处理例子[译]
2024-01-25 09:25:10
Python算法中的时间复杂度问题
2021-03-20 04:52:50
![](https://img.aspxhome.com/file/2023/3/78573_0s.jpg)