码迷,mamicode.com
首页 > 其他好文 > 详细

[Go] 轻量服务器框架基础TCP服务模块

时间:2019-12-15 14:19:33      阅读:68      评论:0      收藏:0      [点我收藏+]

标签:package   ring   inter   listener   top   int   nil   创建   自己的   

框架要先把整体的结构定义好,一般都是在$GOPATH目录的src下建立自己的目录

技术图片

 

 zinterface是一些接口的定义

znet就是接口的具体实现

IServer.go

package zinterface

type IServer interface{
    Start()
    Stop()
    Server()
}

server.go一个tcp服务端的基本业务,简单的原样回显

package znet

import (
    "fmt"
    "log"
    "net"
    "zinx/zinterface"
)

type Server struct {
    Name      string
    IP        string
    IPversion string
    Port      int
}

func (s *Server) Start() {
    log.Printf("%s %s:%d start...\n", s.Name, s.IP, s.Port)
    addr, err := net.ResolveTCPAddr(s.IPversion, fmt.Sprintf("%s:%d", s.IP, s.Port))
    if err != nil {
        log.Println("resolve tcp addr err ", err)
        return
    }
    listener, err := net.ListenTCP(s.IPversion, addr)
    if err != nil {
        log.Println("listen tcp err ", err)
        return
    }
    go func() {
        for {
            conn, err := listener.AcceptTCP()
            if err != nil {
                log.Println("accept tcp err ", err)
                continue
            }
            go func() {

                for {
                    b := make([]byte, 512)
                    len, err := conn.Read(b)
                    if err != nil {
                        log.Println("read tcp err ", err)
                        continue
                    }
                    if _, err := conn.Write(b[:len]); err != nil {
                        log.Println("write tcp err ", err)
                        continue
                    }
                }
            }()
        }
    }()

}
func (s *Server) Stop() {

}
func (s *Server) Server() {
    s.Start()
    select{}
}
func NewServer(name string) zinterface.IServer {
    s := &Server{
        Name:      name,
        IP:        "0.0.0.0",
        IPversion: "tcp4",
        Port:      8999,
    }
    return s
}

单独在src下创建测试目录

技术图片

 

 server.go

package main

import (
    "zinx/znet"
)
func main()  {
    server:=znet.NewServer("[zinx]")
    server.Server()
}

 

[Go] 轻量服务器框架基础TCP服务模块

标签:package   ring   inter   listener   top   int   nil   创建   自己的   

原文地址:https://www.cnblogs.com/taoshihan/p/12043825.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!