温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

golang的网络编程tcp

发布时间:2020-07-19 11:11:00 来源:网络 阅读:379 作者:ck_god 栏目:编程语言
// code_050_socket_knowledge project main.go
package main

import (
    "fmt"
)

//TCP的C/S架构
//TCP客户端:net.Dial()   Write()  Read()  Close()
//TCP服务器:net.Listen() Accept() Read()  Write() Close()
/*
  Unix基本哲学之一就是“一切皆文件”,
  都可以用“打开open –> 读写write/read –> 关闭close”模式来操作。
  Socket就是该模式的一个实现,网络的Socket数据传输是一种特殊的I/O,Socket也是一种文件描述符。
  Socket也具有一个类似于打开文件的函数调用:Socket(),该函数返回一个整型的Socket描述符,
  随后的连接建立、数据传输等操作都是通过该Socket实现的
*/

//常用的Socket类型有两种:流式Socket(SOCK_STREAM)和数据报式Socket(SOCK_DGRAM)。

func main() {
    fmt.Println("Hello World!")
}

服务器

// code_051_tcp_service project main.go
package main

import (
    "fmt"
    "log"
    "net"
    "strings"
)

func dealConn(conn net.Conn) {
    defer conn.Close()

    ipAddr := conn.RemoteAddr().String()
    fmt.Println(ipAddr, "连接成功")

    buf := make([]byte, 1024)
    for {
        //阻塞等待用户发送的数据
        n, err := conn.Read(buf)
        if err != nil {
            fmt.Println(err)
            return
        }

        //切片截取,只截取有效数据
        result := buf[:n]
        fmt.Printf("接收到数据来自[%s]==>[%d]:%s\n", ipAddr, n, string(result))
        if "exit" == string(result) {
            fmt.Println(ipAddr, "退出连接")
            return
        }
        conn.Write([]byte(strings.ToUpper(string(result))))
    }
}

func main() {
    listenner, err := net.Listen("tcp", "127.0.0.1:8001")
    //go中的接口被占用报错:An attempt was made to access a socket in a way forbidden by its access permissions.
    if err != nil {
        log.Fatal(err) //log.Fatal()会产生panic
    }

    for {
        conn, err := listenner.Accept()
        if err != nil {
            log.Println(err)
            continue
        }
        go dealConn(conn)
    }

}

客户端:

// code_052_tcp_client project main.go
package main

import (
    "fmt"
    "log"
    "net"
)

func main() {
    //客户端主动连接服务器
    conn, err := net.Dial("tcp", "127.0.0.1:8001")
    if err != nil {
        log.Fatal(err) //log.Fatal()会产生panic
        return
    }

    defer conn.Close() //关闭

    buf := make([]byte, 1024) //缓冲区
    for {
        fmt.Printf("请输入发送的内容:")
        fmt.Scan(&buf) //相当于Python中的input-->>buf = input("请输入发送的内容")
        fmt.Printf("发送的内容:%s\n", string(buf))

        conn.Write(buf)

        n, err := conn.Read(buf)
        if err != nil {
            fmt.Println(err)
            return
        }
        result := buf[:n]
        fmt.Printf("接收到数据[%d]:%s\n", n, string(result))
    }

}
向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI