Go 第18章 tcp Go 第18章 tcp

2023-09-26

一、简单连接

  • net.DialTCP("tcp", nil, tcpAddr)

  • net.ListenTCP(协议, addr)

  • net.ResolveTCPAddr(协议, 端口)

服务端

package main

import (
   "fmt"
   "net"
)

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   listener, _ := net.ListenTCP("tcp", tcpAddr)
   for {
      conn, err := listener.AcceptTCP()
      if err != nil {
         fmt.Println(err)
         return
      }
      go handleConnection(conn)
   }
}

func handleConnection(conn *net.TCPConn) {
   fmt.Println(conn.RemoteAddr().String())
}

客户端

package main

import "net"

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   _, _ = net.DialTCP("tcp", nil, tcpAddr)
}

二、客户端通过代码发送消息

服务端

package main

import (
   "fmt"
   "net"
)

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   listener, _ := net.ListenTCP("tcp", tcpAddr)
   for {
      conn, err := listener.AcceptTCP()
      if err != nil {
         fmt.Println(err)
         return
      }
      go handleConnection(conn)
   }
}

func handleConnection(conn *net.TCPConn) {
   for {
      buf := make([]byte, 1024)
      n, err := conn.Read(buf)
      if err != nil {
         fmt.Println(err)
         break
      }
      str := string(buf[0:n])
      fmt.Println(conn.RemoteAddr().String(), str)
   }
}

客户端

package main

import (
   "fmt"
   "net"
)

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   conn, _ := net.DialTCP("tcp", nil, tcpAddr)
   _, err := conn.Write([]byte("申请出战"))
   if err != nil {
      fmt.Println(err)
      return
   }
}

三、客户端通过命令行发送消息

服务端

package main

import (
   "fmt"
   "net"
)

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   listener, _ := net.ListenTCP("tcp", tcpAddr)
   for {
      conn, err := listener.AcceptTCP()
      if err != nil {
         fmt.Println(err)
         return
      }
      go handleConnection(conn)
   }
}

func handleConnection(conn *net.TCPConn) {
   for {
      buf := make([]byte, 1024)
      n, err := conn.Read(buf)
      if err != nil {
         fmt.Println(err)
         break
      }
      str := string(buf[0:n])
      fmt.Println(conn.RemoteAddr().String(), str)
   }
}

客户端

package main

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

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   conn, _ := net.DialTCP("tcp", nil, tcpAddr)
   reader := bufio.NewReader(os.Stdin)
   for {
      bytes, _, _ := reader.ReadLine()
      _, err := conn.Write(bytes)
      if err != nil {
         fmt.Println(err)
         break
      }
   }
}

四、服务端发送消息

服务端

package main

import (
   "fmt"
   "net"
)

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   listener, _ := net.ListenTCP("tcp", tcpAddr)
   for {
      conn, err := listener.AcceptTCP()
      if err != nil {
         fmt.Println(err)
         return
      }
      go handleConnection(conn)
   }
}

func handleConnection(conn *net.TCPConn) {
   for {
      buf := make([]byte, 1024)
      n, err := conn.Read(buf)
      if err != nil {
         fmt.Println(err)
         break
      }
      str := string(buf[0:n])
      fmt.Println(conn.RemoteAddr().String(), str)
      _, err = conn.Write([]byte("收到了" + str))
      if err != nil {
         fmt.Println(err)
         break
      }
   }
}

客户端

package main

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

func main() {
   tcpAddr, _ := net.ResolveTCPAddr("tcp", ":8888")
   conn, _ := net.DialTCP("tcp", nil, tcpAddr)

   reader := bufio.NewReader(os.Stdin)
   for {
      bytes, _, _ := reader.ReadLine()
      _, err := conn.Write(bytes)
      if err != nil {
         fmt.Println(err)
         break
      }
      rb := make([]byte, 1024)
      rn, _ := conn.Read(rb)
      fmt.Println(string(rb[0:rn]))
   }
}
阅读 427