内容简介：版权声明：本文为博主尹成联系QQ77025077,微信18510341407原创文章，欢迎转载侵权不究。 https://blog.csdn.net/yincheng01/article/details/84135860
版权声明：本文为博主尹成联系QQ77025077,微信18510341407原创文章，欢迎转载侵权不究。 https://blog.csdn.net/yincheng01/article/details/84135860
服务端实现
import ( "fmt" "net" "os" "strings" ) func CheckErrorS(err error) { if err != nil { fmt.Println("网络错误", err.Error()) os.Exit(1) } } func Processinfo(conn net.Conn) { buffer := make([]byte, 1024) //开创缓冲区 defer conn.Close() //关闭连接 for { n, err := conn.Read(buffer) //读取数据 CheckErrorS(err) if n != 0 { //拿到客户端地址 remoteAddr := conn.RemoteAddr() msg := string(buffer[:n]) fmt.Println("收到消息",msg, "来自", remoteAddr) if strings.Contains(msg,"钱") { conn.Write([]byte("fuckoff")) break } conn.Write([]byte("已阅："+msg)) } } } func main() { //建立TCP服务器 listener, err := net.Listen("tcp", "127.0.0.1:8898") CheckErrorS(err) defer listener.Close() //关闭网络 fmt.Println("服务器正在等待") for { conn, err := listener.Accept() //新的客户端连接 CheckErrorS(err) //处理每一个客户端 go Processinfo(conn) } }
客户端实现
import ( "fmt" "net" "bufio" "os" ) func CheckErrorC(err error) { if err != nil { fmt.Println("网络错误", err.Error()) os.Exit(1) } } func MessageSend(conn net.Conn) { var msg string reader := bufio.NewReader(os.Stdin) //读取键盘输入 for { lineBytes, _, _ := reader.ReadLine() //读取一行 msg = string(lineBytes) //键盘输入转化为字符串 if msg == "exit" { conn.Close() fmt.Println("客户端关闭") break } _, err := conn.Write([]byte(msg)) //输入写入字符串 if err != nil { conn.Close() fmt.Println("客户端关闭") break } } } func main() { conn, err := net.Dial("tcp", "127.0.0.1:8898") //建立TCP服务器 CheckErrorC(err) //检查错误 defer conn.Close() //发送消息中有阻塞读取标准输入的代码 //为了避免阻塞住消息的接收，所以把它独立的协程中 go MessageSend(conn) buffer := make([]byte, 1024) for { n, err := conn.Read(buffer) CheckErrorC(err) msg := string(buffer[:n]) fmt.Println("收到服务器消息", msg) if msg=="fuckoff"{ break } } fmt.Println("连接已断开") }
学院 Go 语言视频主页
https://edu.csdn.net/lecturer/1928以上就是本文的全部内容，希望本文的内容对大家的学习或者工作能带来一定的帮助，也希望大家多多支持 码农网
猜你喜欢:
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
