Method StartProxy

socketproxy/udpproxy.go:96–151

()

}

func (p *UDPProxy) StartProxy() {
	//p.init()
	p.listenConnMutex.Lock()
	defer p.listenConnMutex.Unlock()
	if p.listenConn != nil {
		return
	}

	bindAddr, err := net.ResolveUDPAddr(p.ProxyType, p.GetListentAddress())

	if err != nil {
		p.log.Errorf("Cannot start proxy[%s]:%s", p.GetKey(), err)
		return
	}

	ln, err := net.ListenUDP(p.ProxyType, bindAddr)
	if err != nil {
		if strings.Contains(err.Error(), " bind: Only one usage of each socket address") {
			p.log.Errorf("监听IP端口[%s]已被占用,proxy[%s]启动失败", p.GetListentAddress(), p.String())
		} else {
			p.log.Errorf("Cannot start proxy[%s]:%s", p.String(), err)
		}
		return
	}

	ln.SetReadBuffer(p.getHandlegoroutineNum() * 4 * 1024 * 1024)
	ln.SetWriteBuffer(p.getHandlegoroutineNum() * 4 * 1024 * 1024)

	p.listenConn = ln

	p.log.Infof("[端口转发][开启][%s]", p.String())

	p.relayChs = make([]chan *udpPackge, p.getHandlegoroutineNum())

	for i := range p.relayChs {
		p.relayChs[i] = make(chan *udpPackge, 1024)
	}

	p.replyCh = make(chan *udpPackge, 1024)
	// if p.targetudpConnItemMap == nil {
	// 	p.targetudpConnItemMap = make(map[string]*udpMapItem)
	// }

	for i := range p.relayChs {
		go p.Forwarder(i, p.relayChs[i])
	}

	go p.replyDataToRemotAddress()

	go p.CheckTargetUDPConnectSessions()

	for i := 0; i < p.getHandlegoroutineNum(); i++ {
		go p.ListenHandler(ln)
	}

}

func (p *UDPProxy) StopProxy() {