ejoy / goscon Goto Github PK

Contributors

Stargazers

Forkers

xebecnan cofyc shenyanjun kerasking dgkang sleepwom macsummer ollyblue littleboss zhukunqian learno eastany sunhj sstuqtd sguzwf jkcmd tzngit jinghuizhai imamandacerny chen2bull supernev wudeng cnsuhao alawnwei ultares andoxz chgliu2018 cppby brinkqiang2go spin6lock stephenmax-zhang hahahaval lxq2537664558 mrvon jayceefun xlwangcs lisg2016 zaxbbun swors xingshuo moulo1982 wyrover signis-bin vbirds sunshuxing qaison shencyx yuufish darklost dff1993 terry8210 kennykwok1 coconutxin interfacekun f2ngwx yuzuochen darjun

流量压缩
包转发：终结连接

性能指标
功能指标： 断线重连次数、重连平均时间、重连平均重传数据量等

解析协议，根据协议转发到不同服务

// NewConn creates a new connection to target server, pair with remoteConn
func (u *upstreams) NewConn(remoteConn *scp.Conn) (conn net.Conn, err error) {
	tserver := remoteConn.TargetServer()
	host := u.GetHost(tserver) // TODO: handle name resolve
	if host == nil {
		err = ErrNoHost
		glog.Errorf("get host <%s> failed: %s", tserver, err.Error())
		return
	}

	addr := host.addrs[rand.Intn(len(host.addrs))]
	**tcpConn, err := net.DialTCP("tcp", nil, addr)**
	if err != nil {
		glog.Errorf("connect to <%s> failed: %s", host.Addr, err.Error())
		return
	}

	option := u.option.Load().(*Option)
	conn, err = upgradeConn(option.Net, tcpConn, remoteConn)
	if err != nil {
		conn.Close()
		return
	}

	err = OnAfterConnected(conn, remoteConn)
	return
}