Go知识库

打造一款属于自己的go语言socket框架

2018-09-02  本文已影响91人  xyt001

前言:

一直对socket编程有很大的兴趣,经过一周多的努力与查阅资料终于打造一款属于自己的go语言socket框架,觉得应该记录下来,和大家一起学习(本人也是菜鸟要是有什么不对的地方欢迎留言指正)。已经把所有代码整合了,希望给个星星支持一下 microSocket

socket介绍:

Socket是应用层与TCP/IP协议族通信的中间软件抽象层,它是一组接口。其实说白了,socket就是系统提供的一组接口,来用于网络编程,既可以tcp也可以用于udp。

下面我们来看看最简单的最简单的例子:

func Listening() {
    tcpListen, err := net.Listen("tcp", ":8565")

    if err != nil {
        panic(err)
    }

    for {
        conn, err := tcpListen.Accept()
        if err != nil {
            log.Println(err)
            continue
        }
        go connHandle(conn)
    }
}
func  connHandle(conn net.Conn, sess *session) {
    defer conn.Close()
    readBuff := make([]byte, 14)
    for {
        n, err := conn.Read(readBuff)
        if err != nil {
                return
        }
        fmt.Println(readBuff[:n])
                
    }
}

通过这短短的代码我们就能实现一个性能非常高的 socket 服务器 ,这要感谢go的协程让一切都变得那么的简单!

我来解释一下上面的代码:
  1. 首先 我们调用 net.listen 传入 网络类型 和ip端口 然后返回 一个 listener
  2. 如果没有错误的话我们就会进入一个无线循环 执行 listener.Accept() 方法,这里是阻塞的,当有客户端连接的时候就会返回一个 conn 对象
  3. 每当一个客户端连接成功,我们就单独开一个协程来处理该连接,大大不必担心协程不够用,协程非常轻,几万个协程一点问题没有
  4. 每个协程里面执行着 connHandle 方法, 首先我们defer conn.close ,确保协程退出的时候关闭该连接,最后我们就是一个无线循环 读取客户端信息,注意这里也是阻塞的!

结论:

当然想要打造一款socket框架,这么点是完全不够的!
一款完善的socket框架包括有:

欢迎看我下一篇内容,打造一款属于自己的go语言socket框架2之socket分包处理 https://www.jianshu.com/p/a56648aa6b7d

上一篇下一篇

猜你喜欢

热点阅读