Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >奇妙的go语言(聊天室的开发)

奇妙的go语言(聊天室的开发)

作者头像
全栈程序员站长
发布于 2022-07-12 08:51:13
发布于 2022-07-12 08:51:13
25900
代码可运行
举报
运行总次数:0
代码可运行

大家好,又见面了,我是全栈君,祝每个程序员都可以多学几门语言。

【 声明:版权全部,欢迎转载,请勿用于商业用途。】

这是一篇关于聊天室开发的博客,原来文章的地址来自于。这篇文章非常具有代表性,对于代码中的函数部分内容,不想多说什么,仅仅是对它的实现进行一些必要的解说。关于代码,大家既能够在这里阅读,也能够跳转到那篇博客,继续阅读。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
package main

import(
	"fmt"
	"os"
	"net"
)

////////////////////////////////////////////////////////
//
//错误检查
//
////////////////////////////////////////////////////////
func checkError(err error,info string) (res bool) {
	
	if(err != nil){
		fmt.Println(info+"  " + err.Error())
		return false
	}
	return true
}

////////////////////////////////////////////////////////
//
//server端接收数据线程
//參数:
//		数据连接 conn
//		通讯通道 messages
//
////////////////////////////////////////////////////////
func Handler(conn net.Conn,messages chan string){
	
	fmt.Println("connection is connected from ...",conn.RemoteAddr().String())
	
	buf := make([]byte,1024)
	for{
		lenght, err := conn.Read(buf)
		if(checkError(err,"Connection")==false){
			conn.Close()
			break
		}
		if lenght > 0{
			buf[lenght]=0
		}
		//fmt.Println("Rec[",conn.RemoteAddr().String(),"] Say :" ,string(buf[0:lenght]))
		reciveStr :=string(buf[0:lenght])
		messages <- reciveStr
			
	}
		
}

////////////////////////////////////////////////////////
//
//server发送数据的线程
//
//參数
//		连接字典 conns
//		数据通道 messages
//
////////////////////////////////////////////////////////
func echoHandler(conns *map[string]net.Conn,messages chan string){
	
	
	for{
		msg:= <- messages
		fmt.Println(msg)
		
		for key,value := range *conns {
			
			fmt.Println("connection is connected from ...",key)
			_,err :=value.Write([]byte(msg))
			if(err != nil){
				fmt.Println(err.Error())
				delete(*conns,key)
			}
			
		}
	}
	
}


////////////////////////////////////////////////////////
//
//启动server
//參数
//	端口 port
//
////////////////////////////////////////////////////////
func StartServer(port string){
		service:=":"+port //strconv.Itoa(port);
		tcpAddr, err := net.ResolveTCPAddr("tcp4", service)
		checkError(err,"ResolveTCPAddr")
		l,err := net.ListenTCP("tcp",tcpAddr)
		checkError(err,"ListenTCP")
		conns:=make(map[string]net.Conn)
		messages := make(chan string,10)
		
		//启动server广播线程
		go echoHandler(&conns,messages)
		
		for  {
			fmt.Println("Listening ...")
			conn,err := l.Accept()
			checkError(err,"Accept")
			fmt.Println("Accepting ...")
			conns[conn.RemoteAddr().String()]=conn
			//启动一个新线程
			go Handler(conn,messages) 
			
		}
		
}


////////////////////////////////////////////////////////
//
//client发送线程
//參数
//		发送连接 conn
//
////////////////////////////////////////////////////////
func chatSend(conn net.Conn){
	
	var input string
	username := conn.LocalAddr().String()
	for {
		
		fmt.Scanln(&input)
		if input == "/quit"{
			fmt.Println("ByeBye..")
			conn.Close()
			os.Exit(0);
		}
		
		
		lens,err :=conn.Write([]byte(username + " Say :::" + input))
		fmt.Println(lens)
		if(err != nil){
			fmt.Println(err.Error())
			conn.Close()
			break
		}
		
	}
	
}

////////////////////////////////////////////////////////
//
//client启动函数
//參数
//		远程ip地址和端口 tcpaddr
//
////////////////////////////////////////////////////////
func StartClient(tcpaddr string){
	
	tcpAddr, err := net.ResolveTCPAddr("tcp4", tcpaddr)
	checkError(err,"ResolveTCPAddr")
	conn, err := net.DialTCP("tcp", nil, tcpAddr)
	checkError(err,"DialTCP")
	//启动client发送线程
	go chatSend(conn)	
	
	//開始client轮训
	buf := make([]byte,1024)
	for{
		
		lenght, err := conn.Read(buf)
		if(checkError(err,"Connection")==false){
			conn.Close()
			fmt.Println("Server is dead ...ByeBye")
			os.Exit(0)
		}
		fmt.Println(string(buf[0:lenght]))
		
	}
}


////////////////////////////////////////////////////////
//
//主程序
//
//參数说明:
//	启动server端:  Chat server [port]				eg: Chat server 9090
//	启动client:    Chat client [Server Ip Addr]:[Server Port]  	eg: Chat client 192.168.0.74:9090
//
////////////////////////////////////////////////////////
func main(){
	
	
	if len(os.Args)!=3  {	
		fmt.Println("Wrong pare")
		os.Exit(0)
	}
	
	if os.Args[1]=="server" && len(os.Args)==3 {
		
		StartServer(os.Args[2])
	}
	
	
	if os.Args[1]=="client" && len(os.Args)==3 {
		
		StartClient(os.Args[2])
	}
	
	
}

主要知识点例如以下:

(1)代码中包含了server和client的内容,假设是server,直接输入./chat server 9090就可以,client也非常easy,输入./chat client :9090就好;

(2)假设是client,事实上就包含了两部分内容,一部分是chatSend函数,接受用户的输入;还有一部分是connect到server,接受相关信息;

(3)假设是server,略微复杂一点,有三个部分组成。第一部分就是不停地accept各个client;第二个就是为每个client创立Handler函数,接受client发来的信息;第三个就是echoHandler函数,它的作用就是将从某一用户接受过来的信息广播给其它全部的client,就是这么简单。

发布者:全栈程序员栈长,转载请注明出处:https://javaforall.cn/118722.html原文链接:https://javaforall.cn

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2021年12月,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
Go语言简单的TCP编程
前期准备 ---- 需要import "net"包 IP类型,其中一个重要的方法是IP.ParseIP(ipaddr string)来判断是否是合法的IP地址 TCP Client ---- func (c *TCPConn) Write(b []byte) (n int, err os.Error)用于发送数据,返回发送的数据长度或者返回错误,是TCPConn的方法 func (c *TCPConn) Read(b []byte) (n int, err os.Error)用于接收数据,返回接收的长度或者
李海彬
2018/03/26
1.1K0
Go语言基于Socket编写服务器端与客户端通信的实例
在golang中,网络协议已经被封装的非常完好了,想要写一个Socket的Server,我们并不用像其他语言那样需要为socket、bind、listen、receive等一系列操作头疼,只要使用Golang中自带的net包即可很方便的完成连接等操作~ 在这里,给出一个最最基础的基于Socket的Server的写法: package main import ( "fmt" "net" "log" "os" ) func main() {
李海彬
2018/03/23
2.3K0
转--Go语言基于Socket编写服务器端与客户端通信的实例
在golang中,网络协议已经被封装的非常完好了,想要写一个Socket的Server,我们并不用像其他语言那样需要为socket、bind、listen、receive等一系列操作头疼,只要使用Golang中自带的net包即可很方便的完成连接等操作~ 在这里,给出一个最最基础的基于Socket的Server的写法: 代码如下: package main import ( "fmt" "net" "log" "os" ) func main()
李海彬
2018/03/22
1.3K0
53. Socket服务三次握手的示例 | 厚土Go学习笔记
什么是三次握手呢?这是服务器和客户端之间沟通的过程。 首先,客户端对服务器发送了条信息。 然后,服务端对客户端说,我收到了。 最后,客户端对服务端说,好的,我知道你收到了。 怎么样?这就是三次握手。哈哈! 服务端,我们先声明本地要监听的地址和端口。 netListent, err := net.Listen("tcp", "localhost:7373") 有开始就有结束,当主函数运行结束时,需要释放资源。 defer netListent.Close() 在服务端做标记,表明现在开始等待客户端访问了。
李海彬
2018/03/19
1.5K0
Golang语言 Socket
1. Socket 简介 常用的 Socket 类型有两种:流式 Socket(SOCK_STREAM)和数据报式Socket(SOCK_DGRAM)。 流式是一种面向连接的 Socket,针对于面向连接的 TCP 服务应用; 数据报式 Socket 是一种无连接的 Socket,对应于无连接的 UDP 服务应用 2. 网络中的进程之间如何通过 Socket 通信呢? 网络层的“ip 地址”可以唯一标识网络中的主机,而传输层的“协议+端口”可以唯一标识主机中的应用程序(进程)。这样利用 三元组(ip 地址,
李海彬
2018/03/21
7980
Go Web---tcp服务器
这部分我们将使用 TCP 协议和之前讲到的协程范式编写一个简单的客户端-服务器应用,一个(web)服务器应用需要响应众多客户端的并发请求:Go 会为每一个客户端产生一个协程用来处理请求。我们需要使用 net 包中网络通信的功能。它包含了处理 TCP/IP 以及 UDP 协议、域名解析等方法。
大忽悠爱学习
2022/08/23
1.8K0
Go Web---tcp服务器
54. 心跳的实现 | 厚土Go学习笔记
在多客户端同时访问服务器的工作模式下,首先要保证服务端的运行正常。因此,Server在和Client建立通讯后,确保连接的及时断开就非常重要。否则,多个客户端长时间占用着连接不关闭,是非常可怕的服务器资源浪费。会使得服务器可服务的客户端数量大幅度减少。 因此,针对短连接和长连接,根据业务的需要,配套不同的处理机制。 短连接 一般建立完连接,就立刻传输数据。传输完数据,连接就关闭。服务端根据需要,设定连接的时长。超过时间长度,就算客户端超时。立刻关闭连接。 长连接 建立连接后,传输数据,然后要保持连接,然后再
李海彬
2018/03/19
2.3K0
54. 心跳的实现 | 厚土Go学习笔记
52. Socket Server 自定义协议的简单实现 | 厚土Go学习笔记
在 Server 和 Client 通讯中,由于网络等原因很有可能会发生数据丢包的现象。如果数据确实,服务端接收的信息不完整,就会造成混乱。 我们就需要在 Server 和 Client 之间建立一个通讯协议,通过协议中的规则,判断当前接收到的信息是否完整。根据信息的完整情况,采取不同的处理方法。 通讯协议 protocol 的核心就是设计一个头部。如果传来的信息不包含这个头部,就说明当前信息和之前的信息是同一条。那么就把当前信息和之前的那条信息合并成一条。 而协议主要包含的功能是封装(Enpack)和解析
李海彬
2018/03/19
2.1K0
52. Socket Server 自定义协议的简单实现 | 厚土Go学习笔记
Go语言实践_实现一(服务器端)对多(客户端)在线聊天室
运用Go语言中的goroutine和通道实现一个简单的一个服务器端对多个客户端的在线聊天
Zoctopus
2018/08/03
2.5K0
Go语言实践_实现一(服务器端)对多(客户端)在线聊天室
Golang——socket
socket 客户端代码 package main import ( "bufio" "fmt" "io" "net" "time" ) func main
羊羽shine
2019/05/29
1K1
golang实现聊天室
package main import ( "fmt" "io" "net" "runtime" "sync" ) //创建读写锁,在高并发时保护公共区的数据,不会出现数据混乱 var rwMutex sync.RWMutex //创建全局的Client结构体 type Client struct { name string //初始name与addr一样 addr string C chan string } //创建全局在线用户列表 var onlineMap = m
用户8785253
2022/08/29
1.2K0
golang实现聊天室
51. Socket服务端和客户端使用TCP协议通讯 | 厚土Go学习笔记
Socket服务器是网络服务中常用的服务器。使用 go 语言实现这个业务场景是很容易的。 这样的网络通讯,需要一个服务端和至少一个客户端。 我们计划构建一个这样的通讯过程。服务端启动后等待客户端的访问。客户端发送一段信息给服务端。服务端接收信息后,再回馈给客户端一段信息。 首先要建立服务端。 服务端最先要做的事情就是“建立Socket端口监听” netListen, err := net.Listen("tcp", "localhost:1024") 这样代码,表明监听的本机端口是 1024,而使用的通讯协
李海彬
2018/03/16
1.2K0
51. Socket服务端和客户端使用TCP协议通讯 | 厚土Go学习笔记
GO语言 TCP传输实例
package main import ( "net" "fmt" ) var ( maxRead = 1100 msgStop = []byte("cmdStop") msgStart = []byte("cmdContinue") ) func main() { hostAndPort := "localhost:54321" listener := initServer(hostAndPort) for { conn, err
李海彬
2018/03/19
9630
golang完成聊天室功能
go语言易于实现高并发,简易聊天室如下: package main import ( "fmt" "net" ) /* 主go程:创建监听socket,for循环accept获取到客户端的conn,开启goroutine HandlerConnect HandlerConnect:创建用户结构体,存入onlineMap,发送用户登录广播 Manager:监听全局的channel message,将读到的消息广播给onlineMap中的所有用户 WriteMsgToClient:读取每个用户自带cha
gzq大数据
2021/05/06
3680
内网隧道之NATBypass
github:https://github.com/cw1997/NATBypass
中龙技术
2022/09/29
4930
内网隧道之NATBypass
【Go 语言社区】GO语言练习:网络编程 ICMP 示例
1、代码 2、编译及运行 ---- 1、Go语言网络编程:ICMP示例代码 icmptest.go 1 package main 2 3 import ( 4 "fmt" 5 "net" 6 "os" 7 "io" 8 "bytes" 9 ) 10 11 func main() { 12 if len(os.Args) != 2 { 13 fmt.Println("Usage : ", os.Args[0], "host
李海彬
2018/03/20
1.6K0
go语言TCP编程入门
服务端 服务端的处理流程 监听端口8888 接收客户端的tcp连接 创建gorountine,处理该链接的请求(通常客户端会通过链接发送请求包) 客户端 客户端的处理流程 建立与服务端的链接 发送请求
程序员小饭
2020/09/07
1.8K0
手把手教你用go语言实现聊天室
手撕代码八百里
2024/01/10
4500
学习go语言编程之网络编程
Golang语言标准库对Socket编程进行了抽象,无论使用什么协议建立什么形式的连接,都只需要调用net.Dial()即可。
编程随笔
2023/10/15
4740
golang使用protobuf
为什么要使用protobuf 最近的项目中,一直使用Json做数据传输。Json用起来的确很方便。但相对于protobuf数据量更大些。做一个移动端应用,为用户省点流量还是很有必要的。正好也可以学习一下protobuf的使用 跟Json相比protobuf性能更高,更加规范 编解码速度快,数据体积小 使用统一的规范,不用再担心大小写不同导致解析失败等蛋疼的问题了 但也失去了一些便利性 改动协议字段,需要重新生成文件。 数据没有可读性 安装 在go中使用protobuf,有两个可选用的包goprotobuf(
李海彬
2018/03/26
5.7K1
相关推荐
Go语言简单的TCP编程
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
本文部分代码块支持一键运行,欢迎体验
本文部分代码块支持一键运行,欢迎体验