Go语言实践_实现一(客户端)对一(服务器端)聊天室

// One-to-one ChatRoom Sever
package main
import (
 "fmt"
 "net"
)
//var ConnMap map[string]*net.TCPConn

func main() {
 listen_socket, err := net.Listen("tcp", "127.0.0.1:8000") //打开监听接口
 if err != nil { //如果有错误
 fmt.Println("sever error")
 }
 defer listen_socket.Close() //延迟服务器端关闭
 fmt.Println("sever is wating ....")
 for {
 conn, err := listen_socket.Accept() //监听客户端的端口
 if err != nil {
 fmt.Println("conn fail ...")
 }
 fmt.Println("connect client successed") //显示服务器端连接成功
 var msg string //声明msg为字符串变量
 for {
 //开始接收客户端发过来的消息
 msg = "" //字符串msg初始为空
 data := make([]byte, 255) //创建并声明数据变量,为255位
 msg_read, err := conn.Read(data) //接收由客户端发来的消息,字节赋值给msg_read,err为错误
 if msg_read == 0 || err != nil { //如果读取的消息为0字节或者有错误
 fmt.Println("err")
 }
 msg_read_str := string(data[0:msg_read]) //将msg_read_str的字节格式转化成字符串形式
 if msg_read_str == "close" { //如果接收到的客户端消息为close
 conn.Write([]byte("close"))
 break
 }
 //fmt.Println(string(data[0:msg_read]))
 fmt.Println("client say: ", msg_read_str) //接收客户端发来的信息

 fmt.Printf("say to client: ") //提示向客户端要说的话
 fmt.Scan(&msg) //输入服务器端要对客户端说的话
 //conn.Write([]byte("hello client\n"))
 //msg_write := []byte(msg)
 conn.Write([]byte(msg)) //把消息发送给客户端
 //此处造成服务器端的端口堵塞
 }
 fmt.Println("client Close\n")
 conn.Close() //关闭连接
 }
}

// One-to-one ChatRoom Client
package main
import (
 "fmt"
 "net"
)
func main() {
 conn, err := net.Dial("tcp", "127.0.0.1:8000")
 if err != nil {
 fmt.Println("conn fail...")
 }
 defer conn.Close()
 fmt.Println("connect sever successed")
 var msg string //声明msg为字符串变量
 for {
 msg = "" //初始化msg为空值
 fmt.Printf("say to sever: ")
 fmt.Scan(&msg) //输入客户端向服务器端要发送的消息
 //fmt.Println(msg)
 //msg_write := []byte(msg)
 //conn.Write(msg_write)
 conn.Write([]byte(msg)) //信息转化成字节流形式并向服务器端发送
 //此处造成客户端程序端口堵塞
 //fmt.Println([]byte(msg))
 //等待服务器端发送信息回来
 data := make([]byte, 255)
 msg_read, err := conn.Read(data)
 if msg_read == 0 || err != nil {
 fmt.Println("err")
 }
 msg_read_str := string(data[0:msg_read])
 if msg_read_str == "close" {
 conn.Write([]byte("close"))
 break
 }
 fmt.Println("sever say:", msg_read_str)
 }
 conn.Close()
}

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传