socket :
网络上的两个程序通过一个双向的通信连接实现数据的交换，这个连接的一端称为一个socket。
建立网络通信连接至少要一对端口号(socket)。socket本质是编程接口(API)，对TCP/IP的封装，TCP/IP也要提供可供程序员做网络开发所用的接口，这就是Socket编程接口；HTTP是轿车，提供了封装或者显示数据的具体形式；Socket是发动机，提供了网络通信的能力。
Socket的英文原义是“孔”或“插座”。作为BSD UNIX的进程通信机制，取后一种意思。通常也称作"套接字"，用于描述IP地址和端口，是一个通信链的句柄，可以用来实现不同虚拟机或不同计算机之间的通信。在Internet上的主机一般运行了多个服务软件，同时提供几种服务。每种服务都打开一个Socket，并绑定到一个端口上，不同的端口对应于不同的服务。Socket正如其英文原义那样，像一个多孔插座。一台主机犹如布满各种插座的房间，每个插座有一个编号，有的插座提供220伏交流电， 有的提供110伏交流电，有的则提供有线电视节目。 客户软件将插头插到不同编号的插座，就可以得到不同的服务。
IP + PORT
ip:用来唯一标识一台主机
port:用来唯一标识一台主机上的服务
1.服务端处理流程：
a.监听端口
b.接收客户端连接
c.处理该连接
2.客户端处理流程
a.建立与服务端的连接
b.进行数据收发
c.关闭连接
服务端：
package main
import(
"fmt"
"net"
)
func main(){
fmt.Println("start server ...")
lisen,err := net.Listen("tcp","0.0.0.0:8000") //监听主机和端口 ip+port
if err != nil {
fmt.Println("listen failed,err:",err)
}
for {
conn,err := lisen.Accept() //conn 标识连接的每个客户端
// fmt.Printf("第一次打印%#v",conn)
if err != nil {
fmt.Println("accept failed ,err:",err)
continue
}
go process(conn) //调用 goroutine处理请求，否则的话只有这个连接关闭才能处理别的连接
}
}
func process(conn net.Conn){
defer conn.Close()
// fmt.Printf("第二次打印#v",conn)
for { //循环读取数据
buf := make([]byte,512)
_,err:= conn.Read(buf) //把数据读取存储到buf中
if err != nil {
fmt.Println("read the data failed,err:",err)
return
}
fmt.Println("read the string is",string(buf))
}
}
客户端：
package main
import(
"fmt"
"net"
"bufio"
"os"
"strings"
)
func main(){
conn, err := net.Dial("tcp","0.0.0.0:8000") //连接服务器端
if err != nil {
fmt.Println("connection failed err:",err)
return
}
defer conn.Close()
inputReader := bufio.NewReader(os.Stdin)
for {
input,_ := inputReader.ReadString('
')
trimmedinput := strings.Trim(input,"
")
if trimmedinput == "Q" {
return
}
_,err = conn.Write([]byte(trimmedinput)) //写数据给服务端
if err != nil {
return
}
}
}
上面实现了客户端向服务端发送数据，服务端读取数据，下面改一下，实现客户端与服务端的一个交互发送读取。
服务端代码 ：
package main
import(
"fmt"
"net"
"bufio"
"os"
"strings"
)
func main(){
fmt.Println("start server ...")
lisen,err := net.Listen("tcp","0.0.0.0:8000") //监听主机和端口 ip+port
if err != nil {
fmt.Println("listen failed,err:",err)
}
for {
conn,err := lisen.Accept() //conn 标识连接的每个客户端
// fmt.Printf("第一次打印%#v",conn)
if err != nil {
fmt.Println("accept failed ,err:",err)
continue
}
go readprocess(conn) //调用 goroutine处理请求，否则的话只有这个连接关闭才能处理别的连接
go writeprocess(conn)
}
}
func readprocess(conn net.Conn){
defer conn.Close()
// fmt.Printf("第二次打印#v",conn)
for { //循环读取数据
buf := make([]byte,512)
_,err:= conn.Read(buf) //把数据读取存储到buf中
if err != nil {
fmt.Println("read the data failed,err:",err)
return
}
fmt.Println("from client:",string(buf))
}
}
func writeprocess(conn net.Conn){
defer conn.Close()
fmt.Println("给客户端回复：")
inputReader := bufio.NewReader(os.Stdin)
for {
input,_ := inputReader.ReadString('
')
trimmedinput := strings.Trim(input,"
")
_,err := conn.Write([]byte(trimmedinput)) //写数据给客户端
if err != nil {
return
}
}
}
客户端代码：
package main
import(
"fmt"
"net"
"bufio"
"os"
"strings"
)
func main(){
conn, err := net.Dial("tcp","0.0.0.0:8000") //连接服务器端
if err != nil {
fmt.Println("connection failed err:",err)
return
}
defer conn.Close()
fmt.Println("给服务端回复：")
inputReader := bufio.NewReader(os.Stdin)
for {
input,_ := inputReader.ReadString('
')
trimmedinput := strings.Trim(input,"
")
if trimmedinput == "Q" {
return
}
_,err = conn.Write([]byte(trimmedinput)) //写数据给服务端
if err != nil {
return
}
go readprocess(conn)
}
}
func readprocess(conn net.Conn){
defer conn.Close()
for{
buf := make([]byte,512)
_,err:= conn.Read(buf) //把数据读取存储到buf中
if err != nil {
fmt.Println("read the data failed,err:",err)
return
}
fmt.Println("from server:",string(buf))
}
}