zoukankan      html  css  js  c++  java
  • [Go] tcp服务下的数据传递


    go中实现一个tcp服务,首先是要监听端口,接收请求,这个地方会被阻塞等待
    当客户端连接过来,会开一个grountine去处理这条客户端的tcp连接,因此可以同时处理多条连接

    在连接中,要循环的去读取客户端传递过来的数据,这样就可以不停的处理客户端的请求数据
    在读取数据的时候,每次我只读一个字节,这样方便查看接收到什么数据,因此读取数据的时候也要循环,拼接收到的数据,在这个循环中如果读取大小为0或者读取的这个字节为 时,我就退出循环。

    因为 的ascii编码为10,所以我收到的这一个字节切片的数据tmpByte[0]为10的时候就断掉

    可以通过下面代码的运行看一下收取到的数据,客户端传递一个英文字符,和传递一个中文字符所收取到的具体数据,参照ascii对照表

    客户端传递:a
    服务端收到:
    1 [97] 一个字节,ascii编码为97,对应 a
    1 [13] 一个字节,ascii编码为13,对应 控制字符CR,归位键
    1 [10] 一个字节,ascii编码为10,对应 控制字符LF,换行键

    客户端传递:你
    服务端收到:
    1 [228] 三个字节
    1 [189]
    1 [160]
    1 [13] 下面这俩和上面的意思一样
    1 [10]

    ascii编码下,一个英文字符一个字节,utf8编码下,一个中文字符三个字节

    完整代码:

    package main
    
    import (
        "fmt"
        "net"
    )
    
    func main() {
        //监听端口
        listener, _ := net.Listen("tcp", "0.0.0.0:5921")
        //循环阻塞接收,并发处理同时处理多个连接
        for {
            conn, _ := listener.Accept()
            go handleConn(conn)
        }
    }
    func handleConn(conn net.Conn) {
        //循环不停的去处理数据
        for {
            tmpByte := make([]byte, 1)
            var resData []byte
            //循环去读取数据
            for {
                len, _ := conn.Read(tmpByte)
                fmt.Println(len, tmpByte)
                //读到的长度为0,或者读取到换行就断掉
                if len == 0 || tmpByte[0] == 10 {
                    break
                }
                //拼接读到的数据
                resData = append(resData, tmpByte...)
    
            }
            str := fmt.Sprintf("收到:%s
    ", string(resData))
            conn.Write([]byte(str))
        }
    }

     

  • 相关阅读:
    java内存模型
    类、对象和接口
    Python--数据存储:pickle模块的使用讲解
    Python--常用的内置函数
    Python--迭代器和生成器的定义和案例
    Python--作业2--对员工信息文件,实现增删改查操作
    Python--文本基本操作
    Python--字符串基本操作
    Python--字典基本操作
    Python--作业1--购物车程序
  • 原文地址:https://www.cnblogs.com/taoshihan/p/11879335.html
Copyright © 2011-2022 走看看