前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >[Go] tcp服务下的数据传递

[Go] tcp服务下的数据传递

作者头像
唯一Chat
发布2019-11-18 17:07:50
6170
发布2019-11-18 17:07:50
举报
文章被收录于专栏:陶士涵的菜地

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

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

因为\n的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编码下,一个中文字符三个字节

完整代码:

代码语言:javascript
复制
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\n", string(resData))
        conn.Write([]byte(str))
    }
}
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2019-11-17 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档