go Socket编程

2023年10月19日 209次阅读 来源: 吃猫的鱼0

TCP

Socket客户端

获取连接

//1.
tcpAddr, err := net.ResolveTCPAddr("tcp4", ":8080")
checkError(err)
conn, err := net.DialTCP("tcp", nil, tcpAddr)
//2.
addr := "wwww.baidu.com:80" //定义主机名
conn,err := net.Dial("tcp",addr) //拨号操作，需要指定协议。

串行指定读取客户端返回内容大小

package main
import (
    "io"
    "fmt"
    "log"
    "net"
    "reflect"
)
func main() {
    addr := "wwww.baidu.com:80" //定义主机名
    conn,err := net.Dial("tcp",addr) //拨号操作，需要指定协议。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("访问公网IP地址是：",conn.RemoteAddr().String()) /*获取“conn”中的公网地址。注意：最好是加上后面的String方法，因为他们的那些是不一样的哟·当然你打印的时候
        可以不加输出结果是一样的，但是你的内心是不一样的哟！*/
    fmt.Printf("客户端链接的地址及端口是：%v\n",conn.LocalAddr()) //获取到本地的访问地址和端口。
    fmt.Println("“conn.LocalAddr()”所对应的数据类型是：",reflect.TypeOf(conn.LocalAddr()))
    fmt.Println("“conn.RemoteAddr().String()”所对应的数据类型是：",reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服务端发送数据。用n接受返回的数据大小，用err接受错误信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("向服务端发送的数据大小是:",n)

    buf := make([]byte,1024) //定义一个切片的长度是1024。

    n,err = conn.Read(buf) //接收到的内容大小。

    if err != nil && err != io.EOF {  //io.EOF在网络编程中表示对端把链接关闭了。
        log.Fatal(err)
    }
    fmt.Println(string(buf[:n])) //将接受的内容都读取出来。
    conn.Close()  //断开TCP链接。
}

按照指定方式循环读取

package main
import (
    "io"
    "fmt"
    "log"
    "net"
    "reflect"
)
func main() {
    addr := "wwww.baidu.com:80" //定义主机名
    conn,err := net.Dial("tcp",addr) //拨号操作，需要指定协议。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(conn.RemoteAddr().String()) //最好是加上后面的String方法，因为他们的那些是不一样的哟·当然你打印的时候可以不加。
    fmt.Println(conn.LocalAddr())
    fmt.Println(reflect.TypeOf(conn.LocalAddr()))
    fmt.Println(reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服务端发送数据。用n接受返回的数据大小，用err接受错误信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("写入的大小是:",n)

    buf := make([]byte,10) //定义一个切片的长度是1024。

    for  {
        n,err = conn.Read(buf) //接收到的内容大小。
        if err == io.EOF {
            conn.Close()
        }
        fmt.Print(string(buf[:n]))
    }
    fmt.Println(string(buf[:n])) //将接受的内容都读取出来。
}

按行读取

package main
import (
    "io"
    "fmt"
    "log"
    "net"
    "reflect"
    "bufio"
)
func main() {
    addr := "wwww.baidu.com:80" //定义主机名
    conn,err := net.Dial("tcp",addr) //拨号操作，需要指定协议。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println(conn.RemoteAddr().String()) //最好是加上后面的String方法，因为他们的那些是不一样的哟·当然你打印的时候可以不加。
    fmt.Println(conn.LocalAddr())
    fmt.Println(reflect.TypeOf(conn.LocalAddr()))
    fmt.Println(reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服务端发送数据。用n接受返回的数据大小，用err接受错误信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("写入的大小是:",n)

    r := bufio.NewReader(conn) //将这个链接（connection）包装以下。将conn的内容都放入r中，但是没有进行读取，让步我们一会对其进行操作。
    for  {
        line,err := r.ReadString('\n') //将r的内容也就是conn的数据按照换行符进行读取。
        if err == io.EOF {
            conn.Close()
        }
        fmt.Print(line)
    }
}

io读取

package main
import (
    "io"
    "fmt"
    "log"
    "net"
    "reflect"
    "os"
)
func main() {
    addr := "wwww.baidu.com:80" //定义主机名
    conn,err := net.Dial("tcp",addr) //拨号操作，需要指定协议。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("访问公网IP地址以及端口是：",conn.RemoteAddr().String()) /*获取“conn”中的公网地址。注意：最好是加上后面的String方法，因为他们的那些是不一样的哟·当然你打印的时候
        可以不加输出结果是一样的，但是你的内心是不一样的哟！*/
    fmt.Printf("客户端链接的地址及端口是：%v\n",conn.LocalAddr()) //获取到本地的访问地址和端口。
    fmt.Println("“conn.LocalAddr()”所对应的数据类型是：",reflect.TypeOf(conn.LocalAddr()))
    fmt.Println("“conn.RemoteAddr().String()”所对应的数据类型是：",reflect.TypeOf(conn.RemoteAddr().String()))
    n,err := conn.Write([]byte("GET / HTTP/1.1\r\n\r\n")) //向服务端发送数据。用n接受返回的数据大小，用err接受错误信息。
    if err != nil {
        log.Fatal(err)
    }
    fmt.Println("写入的大小是:",n)
    io.Copy(os.Stdout,conn)
    conn.Close()
}

Socket服务端

串行服务端

package main
import (
    "log"
    "net"
    "time"
)
func main() {
    addr := "0.0.0.0:8080" //表示监听本地所有ip的8080端口，也可以这样写：addr := ":8080"
    listener,err := net.Listen("tcp",addr) //使用协议是tcp，监听的地址是addr
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close() //关闭监听的端口
    for  {
        conn,err := listener.Accept() //用conn接收链接
        if err != nil {
            log.Fatal(err)
        }
        conn.Write([]byte("helloword\n"))  //通过conn的wirte方法将这些数据返回给客户端。
        conn.Write([]byte("hello Golang\n"))
        conn.Close() //与客户端断开连接。
    }
}

并发服务端

package main

import (
    "net"
    "log"
    "time"
)

func Handle_conn(conn net.Conn) { //这个是在处理客户端会阻塞的代码。
    conn.Write([]byte(time.Now().Local().String()))//通过conn的wirte方法将这些数据返回给客户端。
    conn.Close() //与客户端断开连接。
}
func main() {
    addr := "0.0.0.0:8080" //表示监听本地所有ip的8080端口，也可以这样写：addr := ":8080"
    listener,err := net.Listen("tcp",addr)
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()

    for  {
        conn,err := listener.Accept() //用conn接收链接
        if err != nil {
            log.Fatal(err)
        }
        go Handle_conn(conn)  //开启多个协程。
    }
}

web并发服务器；

package main

import (
    "net"
    "log"
)

var content = `HTTP/1.1 200 OK
        Date: Sat, 29 Jul 2017 06:18:23 GMT
        Content-Type: text/html
        Connection: Keep-Alive
        Server: BWS/1.1
        X-UA-Compatible: IE=Edge,chrome=1
        BDPAGETYPE: 3
        Set-Cookie: BDSVRTM=0; path=/

<!doctype html>
<html class="no-js">
<head>
  <meta charset="utf-8">
  <meta http-equiv="X-UA-Compatible" content="IE=edge">
  <title>Amaze UI Admin 404 Examples</title>
  <meta name="description" content="这是一个404页面">
  <meta name="keywords" content="404">
  <meta name="viewport" content="width=device-width, initial-scale=1">
  <meta name="renderer" content="webkit">
  <meta http-equiv="Cache-Control" content="no-siteapp" />
  <meta name="apple-mobile-web-app-title" content="Amaze UI" />
  <link rel="stylesheet" href="assets/css/amazeui.min.css"/>
  <link rel="stylesheet" href="assets/css/admin.css">
</head>
<body>
<!--[if lte IE 9]>
<p class="browsehappy">你正在使用<strong>过时</strong>的浏览器，Amaze UI 暂不支持。 请 <a href="http://browsehappy.com/" target="_blank">升级浏览器</a>
  以获得更好的体验！</p>
<![endif]-->
<div >
  <!-- sidebar start -->
  <!-- sidebar end -->

  <!-- content start -->
  <div >
    <div class="admin-content-body">
      <hr>

      <div class="am-g">
        <div class="am-u-sm-12">
          <h2 class="am-text-center am-text-xxxl am-margin-top-lg">404. Not Found</h2>
          <p class="am-text-center">没有找到你要的页面</p>
</div>
</div>
</div>
<!-- content end -->

</div>
<!--[if lt IE 9]>
<script src="http://libs.baidu.com/jquery/1.11.1/jquery.min.js"></script>
<script src="http://cdn.staticfile.org/modernizr/2.8.3/modernizr.js"></script>
<script src="assets/js/amazeui.ie8polyfill.min.js"></script>
<![endif]-->

<!--[if (gte IE 9)|!(IE)]><!-->

</body>
</html>`

func Handle_conn(conn net.Conn) { //这个是在处理客户端会阻塞。
    conn.Write([]byte(content)) //将html的代码返回给客户端，这样客户端在web上访问就可以拿到指定字符。
    conn.Close()
}


func main() {
    addr := "0.0.0.0:8080" //表示监听本地所有ip的8080端口，也可以这样写：addr := ":8080"
    listener,err := net.Listen("tcp",addr)
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()

    for  {
        conn,err := listener.Accept() //用conn接收链接
        if err != nil {
            log.Fatal(err)
        }
        go Handle_conn(conn) //将接受来的链接交给该函数去处理。
    }
}

UDP

客户端

package main

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

func main() {
    if len(os.Args) != 2 {
        fmt.Fprintf(os.Stderr, "Usage: %s host:port", os.Args[0])
        os.Exit(1)
    }
    service := os.Args[1]
    udpAddr, err := net.ResolveUDPAddr("udp4", service)
    checkError(err)
    conn, err := net.DialUDP("udp", nil, udpAddr)
    checkError(err)
    _, err = conn.Write([]byte("anything"))
    checkError(err)
    var buf [512]byte
    n, err := conn.Read(buf[0:])
    checkError(err)
    fmt.Println(string(buf[0:n]))
    os.Exit(0)
}
func checkError(err os.Error) {
    if err != nil {
        fmt.Fprintf(os.Stderr, "Fatal error ", err.String())
        os.Exit(1)
    }
}

服务器

package main

import (
    "fmt"
    "net"
    "os"
    "time"
)

func main() {
    service := ":1200"
    udpAddr, err := net.ResolveUDPAddr("udp4", service)
    checkError(err)
    conn, err := net.ListenUDP("udp", udpAddr)
    checkError(err)
    for {
        handleClient(conn)
    }
}
func handleClient(conn *net.UDPConn) {
    var buf [512]byte
    _, addr, err := conn.ReadFromUDP(buf[0:])
    if err != nil {
        return
    }
    daytime := time.LocalTime().String()
    conn.WriteToUDP([]byte(daytime), addr)
}
func checkError(err os.Error) {
    if err != nil {
        fmt.Fprintf(os.Stderr, "Fatal error ", err.String())
        os.Exit(1)
    }
}
    原文作者：吃猫的鱼0
    原文地址: https://www.jianshu.com/p/29a2f3c78cdf
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞