netx --简单的一个Net框架

2.0.0 架构

一个全新版本,将代码进行了大的整理,每个功能都单独定义到具体的go源文件中,并且重新定义了接口以及架构

                    --------       --------
                   | server |     | client |
                    --------       --------
                        |             |
                         -------------
                               |
                          -----------
                         | bootstrap |
                          -----------
                               |
                          -----------
                         | protocols |
                          -----------
                               |
                           ---------
                          | handler |
                           ---------

Bootstrap

接口定义

   type Bootstrap interface {
      //创建一个新的Server
      NewServer(netType, host string) *Server
      //创建一个信的Client
      NewClient(netType, host string) *Client
      //当连接创立的时候需要被调用,可用于自定义扩展
      Connection(conn net.Conn) (*Context, error)
      //关闭多有的链接
      Close() error
      //获取统计接口信息
      GetStatInfo() StatInfo
   }

创建Bootstrap

func NewBootStrap(config *Config, contextFactory *ContextFactory, connectionSetting func(conn net.Conn)) Bootstrap

其中Config主要用于设置Bootstrap连接数限制以及是否并发处理,将来可能还需要扩展

 type Config struct {
	//最大连接数
	MaxConnection int
	//最大并发处理个数
	MaxConcurrentHandler int
	//是否顺序处理消息,默认false,即可以并发处理消息
	OrderHandler bool
}

func connectionSetting(conn net.Conn)方法主要是在创建连接的时候对net.Conn的属性进行自定义的扩展,没有默认方法,将来优化后可能会有默认方法

contextFactory的创建需要使用

func NewContextFactory(initContextFunc func(context *Context)) *ContextFactory

在建立连接后创建Context的时候对Context进行初始化设置,如设置protocol,handler等

Bootstrap关闭

调用Close()方法,将会关闭由Bootstrap管理的所有Connection.

Server&Client

创建Server

调用Bootstrap.NewServer()来创建,==目前仅支持TCP==

Server的启动

调用Server.Bind()来启动监听.如果想要监听多个端口,请创建多了Server,可以共用一个Bootstrap来管理链接

创建Client

调用Bootstrap.NewClient()来创建,==目前仅支持TCP==

Client启动

调用Client.Client(timeout time.Duration)

例子

func TestServer(t *testing.T) {
	contextFactory := NewContextFactory(func(context *Context) {
		//设置
		context.SetProtocols([]Protocol{new(defaultProtocol)})
		context.SetHandler(new(testHandler))
	})
	bootstrap := NewBootStrap(new(Config), contextFactory, nil)
	server := bootstrap.NewServer("tcp", "127.0.0.1:9991")
	err := server.Bind()
	if err != nil {
		t.Fatalf("启动服务器出现错误:%s", err)
	}
	client := bootstrap.NewClient("tcp", "127.0.0.1:9991")
	err = client.Connect(3 * time.Second)
	if err != nil {
		t.Fatalf("连接服务器出现错误:%s", err)
	}
	context := client.GetContext()
	for i := 0; i < 10; i++ {
		context.Write([]byte(fmt.Sprintln("开始了\nnext")))
	}
	time.Sleep(time.Millisecond * 300)
	context.Close()
	server.Close()
	bootstrap.Close()
}

备忘:

1. 考虑提供https://github.com/google/gopacket.git的引用
2. 考虑内存池的使用