package main
import(
"fmt"
"net"
//"io"
)
/*
服务端功能:
process(conn net.Conn) 这个是一个处理线程,主函数中每接收一个客户端访问,就是调用这个线程。
*/
func process(conn net.Conn){
//我们循环的接收客户端发送的数据
defer conn.Close() //关闭conn
for{
//创建一个新的切片
buf:=make([]byte,1024)
//1.等待客户端通过conn发送信息
//2.如果客户端没有write【发送】,那么协程就阻塞在这里
fmt.Printf("服务端等待客户端%s发送信息\n",conn.RemoteAddr().String())
n,err:=conn.Read(buf) //从conn读取
if err!=nil{
fmt.Printf("客户端退出err=%v",err)
return
}
//3.显示客户端发送的内容到服务器的终端
fmt.Println(string(buf[:n]))
}
}
func main() {
fmt.Println("服务器开始监听:...")
//net.Listen("tcp","0.0.0.0:8888")
//1.tcp 标识使用的网络协议是tcp
//2.
//"0.0.0.0:8888"--本地监听8888端口
listen,err:=net.Listen("tcp","0.0.0.0:8888")
if err!=nil{
fmt.Println("listen err=",err)
return
}
defer listen.Close() //延时关闭listen
//循环等待客户端来连接我
for{
//等待客户端连接
fmt.Println("等待客户端来连接....")
conn,err:=listen.Accept()
if err!=nil{
fmt.Println("Aceept()err=",err)
}else {
fmt.Printf("Accept()success con=%v 客户端Ip=%v\n",
conn,conn.RemoteAddr().String())
}
//这里准备一个协程,为客户端服务
go process(conn)
}
}
上述数服务器端,我们可以用我们的电脑带有的telnet登录这个服务进行测试
服务端写好了,我们就是可以通过电脑的telnet 可以访问服务了。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)