feat:依赖精简

.asf.yaml

-notifications:
-    commits:      commits@dubbo.apache.org
-    issues:       notifications@dubbo.apache.org
-    pullrequests: notifications@dubbo.apache.org
-    jira_options: link label link label

.travis.yml

-language: go
-
-os:
-  - linux
-
-go:
-  - "1.13"
-
-env:
-  - GO111MODULE=on
-
-install: true
-
-script:
-  # license-check
-  - echo 'start license check'
-  - sh before_validate_license.sh
-  - chmod u+x /tmp/tools/license/license-header-checker
-  - go fmt ./... && [[ -z `git status -s` ]]
-  - /tmp/tools/license/license-header-checker -v -a -r -i vendor  /tmp/tools/license/license.txt . go  && [[ -z `git status -s` ]]
-  - go mod vendor && go test $(go list ./... | grep -v vendor | grep -v demo) -coverprofile=coverage.txt -covermode=atomic
-
-after_success:
-  - bash <(curl -s https://codecov.io/bash)
-
-notifications:
-  webhooks: https://oapi.dingtalk.com/robot/send?access_token=75f4f1ec3868508aa89e5a5d6f9d342216809df3ebc8a78c8ae8722848e06166
\ No newline at end of file

CHANGE.md

-# Release Notes
----
-
-## 1.4.0
-- [Impl: move taskpool at endpoint layer](https://github.com/apache/dubbo-getty/pull/50)
-
-## 1.3.x
-- [Fix: ExposeMaxWheelTimeSpan](https://github.com/apache/dubbo-getty/pull/46)
-- [Impl: tls support](https://github.com/apache/dubbo-getty/pull/44)
-- [Fix: send multiple pkgs repetitive](https://github.com/apache/dubbo-getty/pull/39)
-- [Impl: StreamServer & PacketServer](https://github.com/apache/dubbo-getty/pull/38)
-- [Impl: listen on random local por](https://github.com/apache/dubbo-getty/pull/37)
-- [Impl: reduce syscall and memcopy for multiple package](https://github.com/apache/dubbo-getty/pull/36)
-- [Impl: enlarge time wheel span](https://github.com/apache/dubbo-getty/commit/a57b22edbb3a7de383ad7a94387000bfd4eca194)
-- [Fix: skip the log output of EOF error](https://github.com/apache/dubbo-getty/pull/26) 
-- [Impl: add travis](https://github.com/apache/dubbo-getty/pull/28)
-- [Impl: add writev](https://github.com/apache/dubbo-getty/pull/26)
\ No newline at end of file

before_validate_license.sh

-#
-#  Licensed to the Apache Software Foundation (ASF) under one or more
-#  contributor license agreements.  See the NOTICE file distributed with
-#  this work for additional information regarding copyright ownership.
-#  The ASF licenses this file to You under the Apache License, Version 2.0
-#  (the "License"); you may not use this file except in compliance with
-#  the License.  You may obtain a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-#  Unless required by applicable law or agreed to in writing, software
-#  distributed under the License is distributed on an "AS IS" BASIS,
-#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#  See the License for the specific language governing permissions and
-#  limitations under the License.
-
-remoteLicenseCheckerPath="https://github.com/dubbogo/resources/raw/master/tools/license"
-remoteLicenseCheckerName="license-header-checker"
-remoteLicenseCheckerURL="${remoteLicenseCheckerPath}/${remoteLicenseCheckerName}"
-remoteLicenseName="license.txt"
-remoteLicenseURL="${remoteLicenseCheckerPath}/${remoteLicenseName}"
-
-licensePath="/tmp/tools/license"
-mkdir -p ${licensePath}
-wget -P "${licensePath}" ${remoteLicenseCheckerURL}
-wget -P "${licensePath}" ${remoteLicenseURL}

benchmark/client/main.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"encoding/binary"
-	"errors"
-	"flag"
-	"fmt"
-	"log"
-	"net"
-	"sync"
-	"sync/atomic"
-	"time"
-)
-
-import (
-	"github.com/dubbogo/gost/sync"
-
-	"github.com/montanaflynn/stats"
-)
-
-import (
-	getty "github.com/apache/dubbo-getty"
-)
-
-var (
-	concurrency = flag.Int("c", 1, "concurrency")
-	total       = flag.Int("n", 1, "total requests for all clients")
-	ip          = flag.String("ip", "127.0.0.1:8090", "server IP")
-	connections = flag.Int("conn", 1, "number of tcp connections")
-
-	taskPoolMode = flag.Bool("taskPool", false, "task pool mode")
-	taskPoolSize = flag.Int("task_pool_size", 2000, "task poll size")
-	pprofPort    = flag.Int("pprof_port", 65431, "pprof http port")
-)
-
-var taskPool gxsync.GenericTaskPool
-
-const (
-	CronPeriod      = 20e9
-	WritePkgTimeout = 1e8
-)
-
-func main() {
-	flag.Parse()
-
-	n := *concurrency
-	m := *total / n
-
-	log.Printf("Servers: %+v\n\n", *ip)
-	log.Printf("concurrency: %d\nrequests per client: %d\n\n", n, m)
-
-	var wg sync.WaitGroup
-	wg.Add(n * m)
-
-	d := make([][]int64, n, n)
-	var trans uint64
-	var transOK uint64
-
-	totalT := time.Now().UnixNano()
-	for i := 0; i < n; i++ {
-		dt := make([]int64, 0, m)
-		d = append(d, dt)
-
-		go func(ii int) {
-			client := getty.NewTCPClient(
-				getty.WithServerAddress(*ip),
-				getty.WithConnectionNumber(*connections),
-				getty.WithClientTaskPool(taskPool),
-			)
-
-			var tmpSession getty.Session
-			NewHelloClientSession := func(session getty.Session) (err error) {
-				pkgHandler := &PackageHandler{}
-				EventListener := &MessageHandler{}
-
-				EventListener.SessionOnOpen = func(session getty.Session) {
-					tmpSession = session
-				}
-
-				tcpConn, ok := session.Conn().(*net.TCPConn)
-				if !ok {
-					panic(fmt.Sprintf("newSession: %s, session.conn{%#v} is not tcp connection", session.Stat(), session.Conn()))
-				}
-
-				if err = tcpConn.SetNoDelay(true); err != nil {
-					return err
-				}
-				if err = tcpConn.SetKeepAlive(true); err != nil {
-					return err
-				}
-				if err = tcpConn.SetKeepAlivePeriod(10 * time.Second); err != nil {
-					return err
-				}
-				if err = tcpConn.SetReadBuffer(262144); err != nil {
-					return err
-				}
-				if err = tcpConn.SetWriteBuffer(524288); err != nil {
-					return err
-				}
-
-				session.SetName("hello")
-				session.SetMaxMsgLen(128 * 1024) // max message package length is 128k
-				session.SetReadTimeout(time.Second)
-				session.SetWriteTimeout(5 * time.Second)
-				session.SetCronPeriod(int(CronPeriod / 1e6))
-				session.SetWaitTime(time.Second)
-
-				session.SetPkgHandler(pkgHandler)
-				session.SetEventListener(EventListener)
-				return nil
-			}
-
-			client.RunEventLoop(NewHelloClientSession)
-
-			for j := 0; j < m; j++ {
-				atomic.AddUint64(&trans, 1)
-
-				t := time.Now().UnixNano()
-				msg := buildSendMsg()
-				_, _, err := tmpSession.WritePkg(msg, WritePkgTimeout)
-				if err != nil {
-					log.Printf("Err:session.WritePkg(session{%s}, error{%v}", tmpSession.Stat(), err)
-				}
-
-				atomic.AddUint64(&transOK, 1)
-
-				t = time.Now().UnixNano() - t
-				d[ii] = append(d[ii], t)
-
-				wg.Done()
-			}
-
-			client.Close()
-		}(i)
-	}
-
-	wg.Wait()
-
-	totalT = time.Now().UnixNano() - totalT
-	totalT = totalT / 1000000
-	log.Printf("took %d ms for %d requests", totalT, n*m)
-
-	totalD := make([]int64, 0, n*m)
-	for _, k := range d {
-		totalD = append(totalD, k...)
-	}
-
-	totalD2 := make([]float64, 0, n*m)
-	for _, k := range totalD {
-		totalD2 = append(totalD2, float64(k))
-	}
-
-	mean, _ := stats.Mean(totalD2)
-	median, _ := stats.Median(totalD2)
-	max, _ := stats.Max(totalD2)
-	min, _ := stats.Min(totalD2)
-	p99, _ := stats.Percentile(totalD2, 99.9)
-
-	log.Printf("sent     requests    : %d\n", n*m)
-	log.Printf("received requests    : %d\n", atomic.LoadUint64(&trans))
-	log.Printf("received requests_OK : %d\n", atomic.LoadUint64(&transOK))
-	log.Printf("throughput  (TPS)    : %d\n", int64(n*m)*1000/totalT)
-	log.Printf("mean: %.f ns, median: %.f ns, max: %.f ns, min: %.f ns, p99: %.f ns\n", mean, median, max, min, p99)
-	log.Printf("mean: %d ms, median: %d ms, max: %d ms, min: %d ms, p99: %d ms\n", int64(mean/1000000), int64(median/1000000), int64(max/1000000), int64(min/1000000), int64(p99/1000000))
-}
-
-type MessageHandler struct {
-	SessionOnOpen func(session getty.Session)
-}
-
-func (h *MessageHandler) OnOpen(session getty.Session) error {
-	log.Printf("OnOpen session{%s} open", session.Stat())
-	if h.SessionOnOpen != nil {
-		h.SessionOnOpen(session)
-	}
-	return nil
-}
-
-func (h *MessageHandler) OnError(session getty.Session, err error) {
-	log.Printf("OnError session{%s} got error{%v}, will be closed.", session.Stat(), err)
-}
-
-func (h *MessageHandler) OnClose(session getty.Session) {
-	log.Printf("hhf OnClose session{%s} is closing......", session.Stat())
-}
-
-func (h *MessageHandler) OnMessage(session getty.Session, pkg interface{}) {
-	log.Printf("OnMessage....")
-	s, ok := pkg.(string)
-	if !ok {
-		log.Printf("illegal package{%#v}", pkg)
-		return
-	}
-	log.Printf("OnMessage: %s", s)
-}
-
-func (h *MessageHandler) OnCron(session getty.Session) {
-	log.Printf("OnCron....")
-}
-
-type PackageHandler struct{}
-
-func (h *PackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error) {
-	dataLen := len(data)
-	if dataLen < 4 {
-		return nil, 0, nil
-	}
-
-	start := 0
-	pos := start + 4
-	pkgLen := int(binary.LittleEndian.Uint32(data[start:pos]))
-	if dataLen < pos+pkgLen {
-		return nil, pos + pkgLen, nil
-	}
-	start = pos
-
-	pos = start + pkgLen
-	s := string(data[start:pos])
-
-	return s, pos, nil
-}
-
-func (h *PackageHandler) Write(ss getty.Session, p interface{}) ([]byte, error) {
-	pkg, ok := p.(string)
-	if !ok {
-		log.Printf("illegal pkg:%+v", p)
-		return nil, errors.New("invalid package")
-	}
-
-	pkgLen := int32(len(pkg))
-	pkgStreams := make([]byte, 0, 4+len(pkg))
-
-	// pkg len
-	start := 0
-	pos := start + 4
-	binary.LittleEndian.PutUint32(pkgStreams[start:pos], uint32(pkgLen))
-	start = pos
-
-	// pkg
-	pos = start + int(pkgLen)
-	copy(pkgStreams[start:pos], pkg[:])
-
-	return pkgStreams[:pos], nil
-}
-
-func buildSendMsg() string {
-	return "Now we know what the itables look like, but where do they come from? Go's dynamic type conversions mean that it isn't reasonable for the compiler or linker to precompute all possible itables: there are too many (interface type, concrete type) pairs, and most won't be needed. Instead, the compiler generates a type description structure for each concrete type like Binary or int or func(map[int]string). Among other metadata, the type description structure contains a list of the methods implemented by that type. Similarly, the compiler generates a (different) type description structure for each interface type like Stringer; it too contains a method list. The interface runtime computes the itable by looking for each method listed in the interface type's method table in the concrete type's method table. The runtime caches the itable after generating it, so that this correspondence need only be computed once。"
-}

benchmark/loop_client/main.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"encoding/binary"
-	"errors"
-	"flag"
-	"fmt"
-	"log"
-	"net"
-	"time"
-)
-
-import (
-	"github.com/dubbogo/gost/sync"
-)
-
-import (
-	getty "github.com/apache/dubbo-getty"
-)
-
-var (
-	concurrency = flag.Int("c", 1, "concurrency")
-	total       = flag.Int("n", 1, "total requests for all clients")
-	ip          = flag.String("ip", "127.0.0.1:8090", "server IP")
-	connections = flag.Int("conn", 1, "number of tcp connections")
-
-	taskPoolMode = flag.Bool("taskPool", false, "task pool mode")
-	taskPoolSize = flag.Int("task_pool_size", 2000, "task poll size")
-	pprofPort    = flag.Int("pprof_port", 65431, "pprof http port")
-)
-
-var taskPool gxsync.GenericTaskPool
-
-const (
-	CronPeriod      = 20e9
-	WritePkgTimeout = 1e8
-)
-
-func main() {
-	flag.Parse()
-
-	n := *concurrency
-
-	log.Printf("Servers: %+v\n\n", *ip)
-	for i := 0; i < n; i++ {
-		go func(ii int) {
-			client := getty.NewTCPClient(
-				getty.WithServerAddress(*ip),
-				getty.WithConnectionNumber(*connections),
-				getty.WithClientTaskPool(taskPool),
-			)
-
-			var tmpSession getty.Session
-			NewHelloClientSession := func(session getty.Session) (err error) {
-				pkgHandler := &PackageHandler{}
-				EventListener := &MessageHandler{}
-
-				EventListener.SessionOnOpen = func(session getty.Session) {
-					tmpSession = session
-				}
-
-				tcpConn, ok := session.Conn().(*net.TCPConn)
-				if !ok {
-					panic(fmt.Sprintf("newSession: %s, session.conn{%#v} is not tcp connection", session.Stat(), session.Conn()))
-				}
-
-				if err = tcpConn.SetNoDelay(true); err != nil {
-					return err
-				}
-				if err = tcpConn.SetKeepAlive(true); err != nil {
-					return err
-				}
-				if err = tcpConn.SetKeepAlivePeriod(10 * time.Second); err != nil {
-					return err
-				}
-				if err = tcpConn.SetReadBuffer(262144); err != nil {
-					return err
-				}
-				if err = tcpConn.SetWriteBuffer(524288); err != nil {
-					return err
-				}
-
-				session.SetName("hello")
-				session.SetMaxMsgLen(128 * 1024) // max message package length is 128k
-				session.SetReadTimeout(time.Second)
-				session.SetWriteTimeout(5 * time.Second)
-				session.SetCronPeriod(int(CronPeriod / 1e6))
-				session.SetWaitTime(time.Second)
-
-				session.SetPkgHandler(pkgHandler)
-				session.SetEventListener(EventListener)
-				return nil
-			}
-
-			client.RunEventLoop(NewHelloClientSession)
-
-			for {
-				msg := buildSendMsg()
-				_, _, err := tmpSession.WritePkg(msg, WritePkgTimeout)
-				if err != nil {
-					log.Printf("Err:session.WritePkg(session{%s}, error{%v}", tmpSession.Stat(), err)
-					tmpSession.Close()
-				}
-			}
-		}(i)
-	}
-
-	c := make(chan int)
-	<-c
-}
-
-type MessageHandler struct {
-	SessionOnOpen func(session getty.Session)
-}
-
-func (h *MessageHandler) OnOpen(session getty.Session) error {
-	log.Printf("OnOpen session{%s} open", session.Stat())
-	if h.SessionOnOpen != nil {
-		h.SessionOnOpen(session)
-	}
-	return nil
-}
-
-func (h *MessageHandler) OnError(session getty.Session, err error) {
-	log.Printf("OnError session{%s} got error{%v}, will be closed.", session.Stat(), err)
-}
-
-func (h *MessageHandler) OnClose(session getty.Session) {
-	log.Printf("hhf OnClose session{%s} is closing......", session.Stat())
-}
-
-func (h *MessageHandler) OnMessage(session getty.Session, pkg interface{}) {
-	log.Printf("OnMessage....")
-	s, ok := pkg.(string)
-	if !ok {
-		log.Printf("illegal package{%#v}", pkg)
-		return
-	}
-	log.Printf("OnMessage: %s", s)
-}
-
-func (h *MessageHandler) OnCron(session getty.Session) {
-	log.Printf("OnCron....")
-}
-
-type PackageHandler struct{}
-
-func (h *PackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error) {
-	dataLen := len(data)
-	if dataLen < 4 {
-		return nil, 0, nil
-	}
-
-	start := 0
-	pos := start + 4
-	pkgLen := int(binary.LittleEndian.Uint32(data[start:pos]))
-	if dataLen < pos+pkgLen {
-		return nil, pos + pkgLen, nil
-	}
-	start = pos
-
-	pos = start + pkgLen
-	s := string(data[start:pos])
-
-	return s, pos, nil
-}
-
-func (h *PackageHandler) Write(ss getty.Session, p interface{}) ([]byte, error) {
-	pkg, ok := p.(string)
-	if !ok {
-		log.Printf("illegal pkg:%+v", p)
-		return nil, errors.New("invalid package")
-	}
-
-	pkgLen := int32(len(pkg))
-	pkgStreams := make([]byte, 0, 4+len(pkg))
-
-	// pkg len
-	start := 0
-	pos := start + 4
-	binary.LittleEndian.PutUint32(pkgStreams[start:pos], uint32(pkgLen))
-	start = pos
-
-	// pkg
-	pos = start + int(pkgLen)
-	copy(pkgStreams[start:pos], pkg[:])
-
-	return pkgStreams[:pos], nil
-}
-
-func buildSendMsg() string {
-	return "Now we know what the itables look like, but where do they come from? Go's dynamic type conversions mean that it isn't reasonable for the compiler or linker to precompute all possible itables: there are too many (interface type, concrete type) pairs, and most won't be needed. Instead, the compiler generates a type description structure for each concrete type like Binary or int or func(map[int]string). Among other metadata, the type description structure contains a list of the methods implemented by that type. Similarly, the compiler generates a (different) type description structure for each interface type like Stringer; it too contains a method list. The interface runtime computes the itable by looking for each method listed in the interface type's method table in the concrete type's method table. The runtime caches the itable after generating it, so that this correspondence need only be computed once"
-}

benchmark/server/main.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"encoding/binary"
-	"errors"
-	"flag"
-	"fmt"
-	"log"
-	"net"
-	"net/http"
-	_ "net/http/pprof"
-	"os"
-	"os/signal"
-	"syscall"
-	"time"
-)
-
-import (
-	gxsync "github.com/dubbogo/gost/sync"
-)
-
-import (
-	getty "github.com/apache/dubbo-getty"
-)
-
-var (
-	taskPoolMode = flag.Bool("taskPool", false, "task pool mode")
-	taskPoolSize = flag.Int("task_pool_size", 2000, "task poll size")
-	pprofPort    = flag.Int("pprof_port", 65432, "pprof http port")
-)
-
-var taskPool gxsync.GenericTaskPool
-
-const CronPeriod = 20e9
-
-func main() {
-	flag.Parse()
-
-	go func() {
-		http.ListenAndServe(fmt.Sprintf(":%d", *pprofPort), nil)
-	}()
-
-	options := []getty.ServerOption{getty.WithLocalAddress(":8090")}
-
-	if *taskPoolMode {
-		taskPool = gxsync.NewTaskPoolSimple(*taskPoolSize)
-		options = append(options, getty.WithServerTaskPool(taskPool))
-	}
-
-	server := getty.NewTCPServer(options...)
-
-	go server.RunEventLoop(NewHelloServerSession)
-	log.Printf("getty server start, listening at: 8090")
-
-	signals := make(chan os.Signal, 1)
-	signal.Notify(signals, os.Interrupt, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
-	<-signals
-	server.Close()
-}
-
-func NewHelloServerSession(session getty.Session) (err error) {
-	pkgHandler := &PackageHandler{}
-	EventListener := &MessageHandler{}
-
-	tcpConn, ok := session.Conn().(*net.TCPConn)
-	if !ok {
-		panic(fmt.Sprintf("newSession: %s, session.conn{%#v} is not tcp connection", session.Stat(), session.Conn()))
-	}
-
-	if err = tcpConn.SetNoDelay(true); err != nil {
-		return err
-	}
-	if err = tcpConn.SetKeepAlive(true); err != nil {
-		return err
-	}
-	if err = tcpConn.SetKeepAlivePeriod(10 * time.Second); err != nil {
-		return err
-	}
-	if err = tcpConn.SetReadBuffer(262144); err != nil {
-		return err
-	}
-	if err = tcpConn.SetWriteBuffer(524288); err != nil {
-		return err
-	}
-
-	session.SetName("hello")
-	session.SetMaxMsgLen(128 * 1024) // max message package length is 128k
-	session.SetReadTimeout(time.Second)
-	session.SetWriteTimeout(5 * time.Second)
-	session.SetCronPeriod(int(CronPeriod / 1e6))
-	session.SetWaitTime(time.Second)
-
-	session.SetPkgHandler(pkgHandler)
-	session.SetEventListener(EventListener)
-	return nil
-}
-
-type MessageHandler struct {
-	SessionOnOpen func(session getty.Session)
-}
-
-func (h *MessageHandler) OnOpen(session getty.Session) error {
-	log.Printf("OnOpen session{%s} open", session.Stat())
-	if h.SessionOnOpen != nil {
-		h.SessionOnOpen(session)
-	}
-	return nil
-}
-
-func (h *MessageHandler) OnError(session getty.Session, err error) {
-	log.Printf("OnError session{%s} got error{%v}, will be closed.", session.Stat(), err)
-}
-
-func (h *MessageHandler) OnClose(session getty.Session) {
-	log.Printf("OnClose session{%s} is closing......", session.Stat())
-}
-
-func (h *MessageHandler) OnMessage(session getty.Session, pkg interface{}) {
-	log.Printf("OnMessage....")
-	//s, ok := pkg.(string)
-	//if !ok {
-	//	log.Printf("illegal package{%#v}", pkg)
-	//	return
-	//}
-	//log.Printf("OnMessage: %s", s)
-}
-
-func (h *MessageHandler) OnCron(session getty.Session) {
-	log.Printf("OnCron....")
-}
-
-type PackageHandler struct{}
-
-func (h *PackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error) {
-	dataLen := len(data)
-	if dataLen < 4 {
-		return nil, 0, nil
-	}
-
-	start := 0
-	pos := start + 4
-	pkgLen := int(binary.LittleEndian.Uint32(data[start:pos]))
-	if dataLen < pos+pkgLen {
-		return nil, pos + pkgLen, nil
-	}
-	start = pos
-
-	pos = start + pkgLen
-	s := string(data[start:pos])
-
-	return s, pos, nil
-}
-
-func (h *PackageHandler) Write(ss getty.Session, p interface{}) ([]byte, error) {
-	pkg, ok := p.(string)
-	if !ok {
-		log.Printf("illegal pkg:%+v", p)
-		return nil, errors.New("invalid package")
-	}
-
-	pkgLen := int32(len(pkg))
-	pkgStreams := make([]byte, 0, 4+len(pkg))
-
-	// pkg len
-	start := 0
-	pos := start + 4
-	binary.LittleEndian.PutUint32(pkgStreams[start:pos], uint32(pkgLen))
-	start = pos
-
-	// pkg
-	pos = start + int(pkgLen)
-	copy(pkgStreams[start:pos], pkg[:])
-
-	return pkgStreams[:pos], nil
-}

client.go

@@ -31,10 +31,10 @@ import (
 )
 
 import (
-	"github.com/dubbogo/gost/bytes"
-	"github.com/dubbogo/gost/net"
-	gxsync "github.com/dubbogo/gost/sync"
-	gxtime "github.com/dubbogo/gost/time"
+	"github.com/adamweixuan/gostnops/bytes"
+	"github.com/adamweixuan/gostnops/net"
+	gxsync "github.com/adamweixuan/gostnops/sync"
+	gxtime "github.com/adamweixuan/gostnops/time"
 
 	"github.com/gorilla/websocket"
 

demo/hello/README.md

-# Run Hello Demo
-
-## 1. prepare
-```bash
-
-git clone https://github.com/apache/dubbo-getty.git
-
-cd getty/demo/hello
-```
-
-## 2. run server
-
-run server:
-`go run tcp/server/server.go`
-
-Or run server in task pool mode:
-```bash
-go run tcp/server/server.go -taskPool=true \
-    -task_pool_size=2000 \
-    -pprof_port=60000
-```
-
-## 3. run client
-
-```bash
-go run tcp/client/client.go
-```
-
-Or run client in task pool mode:
-```bash
-go run tcp/client/client.go -taskPool=true \
-    -task_pool_size=50 \
-    -pprof_port=60001
-```
-

demo/hello/consts.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package hello
-
-import (
-	"github.com/apache/dubbo-getty"
-)
-
-const (
-	CronPeriod      = 20e9
-	WritePkgTimeout = 1e8
-)
-
-var log = getty.GetLogger()

demo/hello/hello.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package hello
-
-import (
-	"github.com/apache/dubbo-getty"
-)
-
-var Sessions []getty.Session
-
-func ClientRequest() {
-	for _, session := range Sessions {
-		ss := session
-		go func() {
-			echoTimes := 10
-			for i := 0; i < echoTimes; i++ {
-				_, _, err := ss.WritePkg("hello", WritePkgTimeout)
-				if err != nil {
-					log.Infof("session.WritePkg(session{%s}, error{%v}", ss.Stat(), err)
-					ss.Close()
-				}
-			}
-			log.Infof("after loop %d times", echoTimes)
-		}()
-	}
-}

demo/hello/messagelistener.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package hello
-
-import (
-	"time"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-)
-
-type MessageHandler struct {
-	SessionOnOpen func(session getty.Session)
-}
-
-func (h *MessageHandler) OnOpen(session getty.Session) error {
-	log.Infof("OnOpen session{%s} open", session.Stat())
-	if h.SessionOnOpen != nil {
-		h.SessionOnOpen(session)
-	}
-	return nil
-}
-
-func (h *MessageHandler) OnError(session getty.Session, err error) {
-	log.Infof("OnError session{%s} got error{%v}, will be closed.", session.Stat(), err)
-}
-
-func (h *MessageHandler) OnClose(session getty.Session) {
-	log.Infof("OnClose session{%s} is closing......", session.Stat())
-}
-
-func (h *MessageHandler) OnMessage(session getty.Session, pkg interface{}) {
-	s, ok := pkg.(string)
-	if !ok {
-		log.Infof("illegal package{%#v}", pkg)
-		return
-	}
-
-	log.Infof("OnMessage: %s", s)
-}
-
-func (h *MessageHandler) OnCron(session getty.Session) {
-	active := session.GetActive()
-	if CronPeriod < time.Since(active).Nanoseconds() {
-		log.Infof("OnCorn session{%s} timeout{%s}", session.Stat(), time.Since(active).String())
-		session.Close()
-	}
-}

demo/hello/pkghandler.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package hello
-
-import (
-	"encoding/binary"
-	"errors"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-)
-
-type PackageHandler struct{}
-
-func (h *PackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error) {
-	dataLen := len(data)
-	if dataLen < 4 {
-		return nil, 0, nil
-	}
-
-	start := 0
-	pos := start + 4
-	pkgLen := int(binary.LittleEndian.Uint32(data[start:pos]))
-	if dataLen < pos+pkgLen {
-		return nil, pos + pkgLen, nil
-	}
-	start = pos
-
-	pos = start + pkgLen
-	s := string(data[start:pos])
-
-	return s, pos, nil
-}
-
-func (h *PackageHandler) Write(ss getty.Session, p interface{}) ([]byte, error) {
-	pkg, ok := p.(string)
-	if !ok {
-		log.Infof("illegal pkg:%+v", p)
-		return nil, errors.New("invalid package")
-	}
-
-	pkgLen := int32(len(pkg))
-	pkgStreams := make([]byte, 0, 4+len(pkg))
-
-	// pkg len
-	start := 0
-	pos := start + 4
-	binary.LittleEndian.PutUint32(pkgStreams[start:pos], uint32(pkgLen))
-	start = pos
-
-	// pkg
-	pos = start + int(pkgLen)
-	copy(pkgStreams[start:pos], pkg[:])
-
-	return pkgStreams[:pos], nil
-}

demo/hello/tcp/client/client.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"flag"
-)
-
-import (
-	"github.com/dubbogo/gost/sync"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-	"github.com/apache/dubbo-getty/demo/hello"
-	"github.com/apache/dubbo-getty/demo/hello/tcp"
-	"github.com/apache/dubbo-getty/demo/util"
-)
-
-var (
-	ip          = flag.String("ip", "127.0.0.1", "server IP")
-	connections = flag.Int("conn", 1, "number of tcp connections")
-
-	taskPoolMode = flag.Bool("taskPool", false, "task pool mode")
-	taskPoolSize = flag.Int("task_pool_size", 2000, "task poll size")
-	pprofPort    = flag.Int("pprof_port", 65431, "pprof http port")
-)
-
-var taskPool gxsync.GenericTaskPool
-
-func main() {
-	flag.Parse()
-
-	util.SetLimit()
-
-	util.Profiling(*pprofPort)
-
-	if *taskPoolMode {
-		taskPool = gxsync.NewTaskPoolSimple(*taskPoolSize)
-	}
-
-	client := getty.NewTCPClient(
-		getty.WithServerAddress(*ip+":8090"),
-		getty.WithConnectionNumber(*connections),
-		getty.WithClientTaskPool(taskPool),
-	)
-
-	client.RunEventLoop(NewHelloClientSession)
-
-	go hello.ClientRequest()
-
-	util.WaitCloseSignals(client)
-	taskPool.Close()
-}
-
-// NewHelloClientSession use for init client session
-func NewHelloClientSession(session getty.Session) (err error) {
-	tcp.EventListener.SessionOnOpen = func(session getty.Session) {
-		hello.Sessions = append(hello.Sessions, session)
-	}
-	err = tcp.InitialSession(session)
-	if err != nil {
-		return
-	}
-	return
-}

demo/hello/tcp/config.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package tcp
-
-import (
-	"fmt"
-	"net"
-	"time"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-	"github.com/apache/dubbo-getty/demo/hello"
-)
-
-var (
-	pkgHandler = &hello.PackageHandler{}
-	// EventListener register event callback
-	EventListener = &hello.MessageHandler{}
-)
-
-func InitialSession(session getty.Session) (err error) {
-	// session.SetCompressType(getty.CompressZip)
-
-	tcpConn, ok := session.Conn().(*net.TCPConn)
-	if !ok {
-		panic(fmt.Sprintf("newSession: %s, session.conn{%#v} is not tcp connection", session.Stat(), session.Conn()))
-	}
-
-	if err = tcpConn.SetNoDelay(true); err != nil {
-		return err
-	}
-	if err = tcpConn.SetKeepAlive(true); err != nil {
-		return err
-	}
-	if err = tcpConn.SetKeepAlivePeriod(10 * time.Second); err != nil {
-		return err
-	}
-	if err = tcpConn.SetReadBuffer(262144); err != nil {
-		return err
-	}
-	if err = tcpConn.SetWriteBuffer(524288); err != nil {
-		return err
-	}
-
-	session.SetName("hello")
-	session.SetMaxMsgLen(128 * 1024) // max message package length is 128k
-	session.SetReadTimeout(time.Second)
-	session.SetWriteTimeout(5 * time.Second)
-	session.SetCronPeriod(int(hello.CronPeriod / 1e6))
-	session.SetWaitTime(time.Second)
-
-	session.SetPkgHandler(pkgHandler)
-	session.SetEventListener(EventListener)
-	return nil
-}

demo/hello/tcp/server/server.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"flag"
-)
-
-import (
-	gxsync "github.com/dubbogo/gost/sync"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-	"github.com/apache/dubbo-getty/demo/hello/tcp"
-	"github.com/apache/dubbo-getty/demo/util"
-)
-
-var (
-	taskPoolMode = flag.Bool("taskPool", false, "task pool mode")
-	taskPoolSize = flag.Int("task_pool_size", 2000, "task poll size")
-	pprofPort    = flag.Int("pprof_port", 65432, "pprof http port")
-)
-
-var taskPool gxsync.GenericTaskPool
-
-func main() {
-	flag.Parse()
-
-	util.SetLimit()
-
-	util.Profiling(*pprofPort)
-
-	options := []getty.ServerOption{getty.WithLocalAddress(":8090")}
-
-	if *taskPoolMode {
-		taskPool = gxsync.NewTaskPoolSimple(*taskPoolSize)
-		options = append(options, getty.WithServerTaskPool(taskPool))
-	}
-
-	server := getty.NewTCPServer(options...)
-
-	go server.RunEventLoop(NewHelloServerSession)
-
-	util.WaitCloseSignals(server)
-}
-
-func NewHelloServerSession(session getty.Session) (err error) {
-	err = tcp.InitialSession(session)
-	if err != nil {
-		return
-	}
-	return
-}

demo/hello/tls/certs/ca.key

------BEGIN PRIVATE KEY-----
-MIICdQIBADANBgkqhkiG9w0BAQEFAASCAl8wggJbAgEAAoGBAMBA3wVeTGHZR1Ry
-e/i+J8a2cu5gXwFV6TnObzGM7bLFCO5i9v4mLo4iFzPsHmWDUxKS3Y8iXbu0eYBl
-LoNY0lSvxDx33O+DuwMmVN+DzSD+Eod9zfvwOWHsazYCZT2PhNxnVWIuJXViY4JA
-HUGodjx+QAi6yCAurUZGvYXGgZSBAgMBAAECgYAxRi8i9BlFlufGSBVoGmydbJOm
-bwLKl9dP3o33ODSP9hok5y6A0w5plWk3AJSF1hPLleK9VcSKYGYnt0clmPVHF35g
-bx2rVK8dOT0mn7rz9Zr70jcSz1ETA2QonHZ+Y+niLmcic9At6hRtWiewblUmyFQm
-GwggIzi7LOyEUHrEcQJBAOXxyQvnLvtKzXiqcsW/K6rExqVJVk+KF0fzzVyMzTJx
-HRBxUVgvGdEJT7j+7P2kcTyafve0BBzDSPIaDyiJ+Y0CQQDWCb7jASFSbu5M3Zcd
-Gkr4ZKN1XO3VLQX10b22bQYdF45hrTN2tnzRvVUR4q86VVnXmiGiTqmLkXcA2WWf
-pHfFAkAhv9olUBo6MeF0i3frBEMRfm41hk0PwZHnMqZ6pgPcGnQMnMU2rzsXzkkQ
-OwJnvAIOxhJKovZTjmofdqmw5odlAkBYVUdRWjsNUTjJwj3GRf6gyq/nFMYWz3EB
-RWFdM1ttkDYzu45ctO2IhfHg4sPceDMO1s6AtKQmNI9/azkUjITdAkApNa9yFRzc
-TBaDNPd5KVd58LVIzoPQ6i7uMHteLXJUWqSroji6S3s4gKMFJ/dO+ZXIlgQgfJJJ
-ZDL4cdrdkeoM
------END PRIVATE KEY-----

demo/hello/tls/certs/ca.pem

------BEGIN CERTIFICATE-----
-MIICSjCCAbOgAwIBAgIJAJHGGR4dGioHMA0GCSqGSIb3DQEBCwUAMFYxCzAJBgNV
-BAYTAkFVMRMwEQYDVQQIEwpTb21lLVN0YXRlMSEwHwYDVQQKExhJbnRlcm5ldCBX
-aWRnaXRzIFB0eSBMdGQxDzANBgNVBAMTBnRlc3RjYTAeFw0xNDExMTEyMjMxMjla
-Fw0yNDExMDgyMjMxMjlaMFYxCzAJBgNVBAYTAkFVMRMwEQYDVQQIEwpTb21lLVN0
-YXRlMSEwHwYDVQQKExhJbnRlcm5ldCBXaWRnaXRzIFB0eSBMdGQxDzANBgNVBAMT
-BnRlc3RjYTCBnzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEAwEDfBV5MYdlHVHJ7
-+L4nxrZy7mBfAVXpOc5vMYztssUI7mL2/iYujiIXM+weZYNTEpLdjyJdu7R5gGUu
-g1jSVK/EPHfc74O7AyZU34PNIP4Sh33N+/A5YexrNgJlPY+E3GdVYi4ldWJjgkAd
-Qah2PH5ACLrIIC6tRka9hcaBlIECAwEAAaMgMB4wDAYDVR0TBAUwAwEB/zAOBgNV
-HQ8BAf8EBAMCAgQwDQYJKoZIhvcNAQELBQADgYEAHzC7jdYlzAVmddi/gdAeKPau
-sPBG/C2HCWqHzpCUHcKuvMzDVkY/MP2o6JIW2DBbY64bO/FceExhjcykgaYtCH/m
-oIU63+CFOTtR7otyQAWHqXa7q4SbCDlG7DyRFxqG0txPtGvy12lgldA2+RgcigQG
-Dfcog5wrJytaQ6UA0wE=
------END CERTIFICATE-----

demo/hello/tls/certs/client.key

------BEGIN PRIVATE KEY-----
-MIICeQIBADANBgkqhkiG9w0BAQEFAASCAmMwggJfAgEAAoGBAOxUR9uhvhbeVUIM
-s5WbH0px0mehl2+6sZpNjzvE2KimZpHzMJHukVH0Ffkvhs0b8+S5Ut9VNUAqd3IM
-JCCAEGtRNoQhM1t9Yr2zAckSvbRacp+FL/Cj9eDmyo00KsVGaeefA4Dh4OW+ZhkT
-NKcldXqkSuj1sEf244JZYuqZp6/tAgMBAAECgYEAi2NSVqpZMafE5YYUTcMGe6QS
-k2jtpsqYgggI2RnLJ/2tNZwYI5pwP8QVSbnMaiF4gokD5hGdrNDfTnb2v+yIwYEH
-0w8+oG7Z81KodsiZSIDJfTGsAZhVNwOz9y0VD8BBZZ1/274Zh52AUKLjZS/ZwIbS
-W2ywya855dPnH/wj+0ECQQD9X8D920kByTNHhBG18biAEZ4pxs9f0OAG8333eVcI
-w2lJDLsYDZrCB2ocgA3lUdozlzPC7YDYw8reg0tkiRY5AkEA7sdNzOeQsQRn7++5
-0bP9DtT/iON1gbfxRzCfCfXdoOtfQWIzTePWtURt9X/5D9NofI0Rg5W2oGy/MLe5
-/sXHVQJBAIup5XrJDkQywNZyAUU2ecn2bCWBFjwtqd+LBmuMciI9fOKsZtEKZrz/
-U0lkeMRoSwvXE8wmGLjjrAbdfohrXFkCQQDZEx/LtIl6JINJQiswVe0tWr6k+ASP
-1WXoTm+HYpoF/XUvv9LccNF1IazFj34hwRQwhx7w/V52Ieb+p0jUMYGxAkEAjDhd
-9pBO1fKXWiXzi9ZKfoyTNcUq3eBSVKwPG2nItg5ycXengjT5sgcWDnciIzW7BIVI
-JiqOszq9GWESErAatg==
------END PRIVATE KEY-----

demo/hello/tls/certs/client.pem

------BEGIN CERTIFICATE-----
-MIIC6TCCAlKgAwIBAgIBCjANBgkqhkiG9w0BAQsFADBWMQswCQYDVQQGEwJBVTET
-MBEGA1UECBMKU29tZS1TdGF0ZTEhMB8GA1UEChMYSW50ZXJuZXQgV2lkZ2l0cyBQ
-dHkgTHRkMQ8wDQYDVQQDEwZ0ZXN0Y2EwHhcNMTUxMTEwMDEwOTU4WhcNMjUxMTA3
-MDEwOTU4WjBaMQswCQYDVQQGEwJBVTETMBEGA1UECAwKU29tZS1TdGF0ZTEhMB8G
-A1UECgwYSW50ZXJuZXQgV2lkZ2l0cyBQdHkgTHRkMRMwEQYDVQQDDAp0ZXN0Y2xp
-ZW50MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQDsVEfbob4W3lVCDLOVmx9K
-cdJnoZdvurGaTY87xNiopmaR8zCR7pFR9BX5L4bNG/PkuVLfVTVAKndyDCQggBBr
-UTaEITNbfWK9swHJEr20WnKfhS/wo/Xg5sqNNCrFRmnnnwOA4eDlvmYZEzSnJXV6
-pEro9bBH9uOCWWLqmaev7QIDAQABo4HCMIG/MAkGA1UdEwQCMAAwCwYDVR0PBAQD
-AgXgMB0GA1UdDgQWBBQAdbW5Vml/CnYwqdP3mOHDARU+8zBwBgNVHSMEaTBnoVqk
-WDBWMQswCQYDVQQGEwJBVTETMBEGA1UECBMKU29tZS1TdGF0ZTEhMB8GA1UEChMY
-SW50ZXJuZXQgV2lkZ2l0cyBQdHkgTHRkMQ8wDQYDVQQDEwZ0ZXN0Y2GCCQCRxhke
-HRoqBzAJBgNVHREEAjAAMAkGA1UdEgQCMAAwDQYJKoZIhvcNAQELBQADgYEAf4MM
-k+sdzd720DfrQ0PF2gDauR3M9uBubozDuMuF6ufAuQBJSKGQEGibXbUelrwHmnql
-UjTyfolVcxEBVaF4VFHmn7u6vP7S1NexIDdNUHcULqxIb7Tzl8JYq8OOHD2rQy4H
-s8BXaVIzw4YcaCGAMS0iDX052Sy7e2JhP8Noxvo=
------END CERTIFICATE-----

demo/hello/tls/certs/server0.key

------BEGIN PRIVATE KEY-----
-MIICdwIBADANBgkqhkiG9w0BAQEFAASCAmEwggJdAgEAAoGBANOmffupIGC8YDau
-rOF4eKnHwPszgpkkhWzKsVxhNDBxCVYx4TEjG0XWIO0iyRXupZbUC+7N/8HnEVNa
-8F1jYhng14Iiq99cNQbbnuHHhIztmpocrJTxmnhGzoAnRa1Tb+GnAuRoIHRA/V2c
-VUE9tbikQugFx/SPgXAw6tfWB+YvAgMBAAECgYEAoEq9qzUBgoHoVEGiSPiWWe8g
-5p6yUA1qx2QTQyWTAwT4z0DjjfVKmG99bFsl8+hTnJFnoCp/gnjflEOROwkjp5kG
-m0drqOPx1jeipJjpXYTBu49h+WpZ1PF+KhVtxsIm3OOCvh67iWaKyyOVb5Og8aiR
-jl6dn/TdG/dlGD8AfUECQQDuNMle6p0oU8amC6O9wIMBroxx2nFstzE6O35PLEzG
-/tj0kxxn9Jp2TS9mGaLCzSuXmpjlF4+NOWiBPkrLC2TfAkEA43Xg7uEUkaJAz2/W
-m1lIBTLt+4rIQY/2emh33bDcA+rv8rwwrMMIv17/xPx7bs49YqGG5xufD+Rwl6TL
-qFXYsQJAPrOwagax1aKvwJeBw3oAQhoTKAkLIEXcdGqipe6QSzVcIIz0xjxxyEAr
-AOIwoLxnBCISqwMXq2H4K0UdZPMb2wJAdhdYLY1L6YRMk6XjzImg25oidisKZweA
-FvMv8DgHMj2CUAqmVrt3SivfLH1M9C09L3zfFhOAFHcsgX58gav4MQJBANSBnrHj
-tIq4l8z79CPUIuu3QyeEh+XwY8s5qE5CNTck0U59lzp9NvENHbkx3KO896TTerko
-+8bXHMLkJkHPXms=
------END PRIVATE KEY-----

demo/hello/tls/certs/server0.pem

------BEGIN CERTIFICATE-----
-MIIC8zCCAlygAwIBAgIBCzANBgkqhkiG9w0BAQsFADBWMQswCQYDVQQGEwJBVTET
-MBEGA1UECBMKU29tZS1TdGF0ZTEhMB8GA1UEChMYSW50ZXJuZXQgV2lkZ2l0cyBQ
-dHkgTHRkMQ8wDQYDVQQDEwZ0ZXN0Y2EwHhcNMTUxMTEwMDExNDU1WhcNMjUxMTA3
-MDExNDU1WjBkMQswCQYDVQQGEwJBVTETMBEGA1UECAwKU29tZS1TdGF0ZTEhMB8G
-A1UECgwYSW50ZXJuZXQgV2lkZ2l0cyBQdHkgTHRkMR0wGwYDVQQDDBQqLnRlc3Qu
-Z29vZ2xlLmNvbS5hdTCBnzANBgkqhkiG9w0BAQEFAAOBjQAwgYkCgYEA06Z9+6kg
-YLxgNq6s4Xh4qcfA+zOCmSSFbMqxXGE0MHEJVjHhMSMbRdYg7SLJFe6lltQL7s3/
-wecRU1rwXWNiGeDXgiKr31w1Btue4ceEjO2amhyslPGaeEbOgCdFrVNv4acC5Ggg
-dED9XZxVQT21uKRC6AXH9I+BcDDq19YH5i8CAwEAAaOBwjCBvzAJBgNVHRMEAjAA
-MAsGA1UdDwQEAwIF4DAdBgNVHQ4EFgQUbyZIbUvqmePzv40xa0mMaDxLToYwcAYD
-VR0jBGkwZ6FapFgwVjELMAkGA1UEBhMCQVUxEzARBgNVBAgTClNvbWUtU3RhdGUx
-ITAfBgNVBAoTGEludGVybmV0IFdpZGdpdHMgUHR5IEx0ZDEPMA0GA1UEAxMGdGVz
-dGNhggkAkcYZHh0aKgcwCQYDVR0RBAIwADAJBgNVHRIEAjAAMA0GCSqGSIb3DQEB
-CwUAA4GBAJ21MwMf4WwAjafPKn+8Ng7ordtdp6tlkjt+Xub4l4zMr6FCp6dc/Ceh
-6Hj43zYcKpAe5I6eaVcMc9qcYfUb9i4NVX82dMQpAwpNHgqTzqYt6GYEjF3YhKA7
-uOFdA0OvOFJa14SNdNRk9E1Cd/tElXnLnSE4DOguMNvXz8mRKfnD
------END CERTIFICATE-----

demo/hello/tls/client/client.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"flag"
-	"path/filepath"
-)
-
-import (
-	"github.com/dubbogo/gost/sync"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-	"github.com/apache/dubbo-getty/demo/hello"
-	tls "github.com/apache/dubbo-getty/demo/hello/tls"
-	"github.com/apache/dubbo-getty/demo/util"
-)
-
-var (
-	ip          = flag.String("ip", "127.0.0.1", "server IP")
-	connections = flag.Int("conn", 1, "number of tcp connections")
-
-	taskPoolMode = flag.Bool("taskPool", false, "task pool mode")
-	taskPoolSize = flag.Int("task_pool_size", 2000, "task poll size")
-	pprofPort    = flag.Int("pprof_port", 65431, "pprof http port")
-)
-
-var taskPool gxsync.GenericTaskPool
-
-func main() {
-	flag.Parse()
-
-	util.SetLimit()
-
-	util.Profiling(*pprofPort)
-
-	if *taskPoolMode {
-		taskPool = gxsync.NewTaskPoolSimple(*taskPoolSize)
-	}
-	keyPath, _ := filepath.Abs("./demo/hello/tls/certs/ca.key")
-	caPemPath, _ := filepath.Abs("./demo/hello/tls/certs/ca.pem")
-
-	config := &getty.ClientTlsConfigBuilder{
-		ClientTrustCertCollectionPath: caPemPath,
-		ClientPrivateKeyPath:          keyPath,
-	}
-	client := getty.NewTCPClient(
-		getty.WithServerAddress(*ip+":8090"),
-		getty.WithClientSslEnabled(true),
-		getty.WithClientTlsConfigBuilder(config),
-		getty.WithConnectionNumber(*connections),
-		getty.WithClientTaskPool(taskPool),
-	)
-
-	client.RunEventLoop(NewHelloClientSession)
-
-	go hello.ClientRequest()
-
-	util.WaitCloseSignals(client)
-	taskPool.Close()
-}
-
-// NewHelloClientSession use for init client session
-func NewHelloClientSession(session getty.Session) (err error) {
-	tls.EventListener.SessionOnOpen = func(session getty.Session) {
-		hello.Sessions = append(hello.Sessions, session)
-	}
-	err = tls.InitialSession(session)
-	if err != nil {
-		return
-	}
-	return
-}

demo/hello/tls/config.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package tcp
-
-import (
-	"crypto/tls"
-	"time"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-	"github.com/apache/dubbo-getty/demo/hello"
-)
-
-var (
-	pkgHandler = &hello.PackageHandler{}
-	// EventListener register event callback
-	EventListener = &hello.MessageHandler{}
-)
-
-// InitialSession init session
-func InitialSession(session getty.Session) (err error) {
-	// session.SetCompressType(getty.CompressZip)
-	_, ok := session.Conn().(*tls.Conn)
-	if ok {
-		session.SetName("hello")
-		session.SetMaxMsgLen(128 * 1024) // max message package length is 128k
-		session.SetReadTimeout(time.Second)
-		session.SetWriteTimeout(5 * time.Second)
-		session.SetCronPeriod(int(hello.CronPeriod / 1e6))
-		session.SetWaitTime(time.Second)
-
-		session.SetPkgHandler(pkgHandler)
-		session.SetEventListener(EventListener)
-	}
-	return nil
-}

demo/hello/tls/server/server.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"flag"
-	"path/filepath"
-)
-
-import (
-	gxsync "github.com/dubbogo/gost/sync"
-)
-
-import (
-	"github.com/apache/dubbo-getty"
-	tls "github.com/apache/dubbo-getty/demo/hello/tls"
-	"github.com/apache/dubbo-getty/demo/util"
-)
-
-var (
-	taskPoolMode = flag.Bool("taskPool", false, "task pool mode")
-	taskPoolSize = flag.Int("task_pool_size", 2000, "task poll size")
-	pprofPort    = flag.Int("pprof_port", 65432, "pprof http port")
-	Sessions     []getty.Session
-)
-
-var taskPool gxsync.GenericTaskPool
-
-func main() {
-	flag.Parse()
-
-	util.SetLimit()
-
-	util.Profiling(*pprofPort)
-	serverPemPath, _ := filepath.Abs("./demo/hello/tls/certs/server0.pem")
-	serverKeyPath, _ := filepath.Abs("./demo/hello/tls/certs/server0.key")
-	caPemPath, _ := filepath.Abs("./demo/hello/tls/certs/ca.pem")
-
-	c := &getty.ServerTlsConfigBuilder{
-		ServerKeyCertChainPath:        serverPemPath,
-		ServerPrivateKeyPath:          serverKeyPath,
-		ServerTrustCertCollectionPath: caPemPath,
-	}
-
-	if *taskPoolMode {
-		taskPool = gxsync.NewTaskPoolSimple(*taskPoolSize)
-	}
-	options := []getty.ServerOption{
-		getty.WithLocalAddress(":8090"),
-		getty.WithServerSslEnabled(true),
-		getty.WithServerTlsConfigBuilder(c),
-		getty.WithServerTaskPool(taskPool),
-	}
-
-	server := getty.NewTCPServer(options...)
-
-	go server.RunEventLoop(NewHelloServerSession)
-	util.WaitCloseSignals(server)
-}
-
-func NewHelloServerSession(session getty.Session) (err error) {
-	err = tls.InitialSession(session)
-	Sessions = append(Sessions, session)
-	if err != nil {
-		return
-	}
-
-	return
-}

demo/util/limit_darwin.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package util
-
-func SetLimit() {
-}

demo/util/limit_linux.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package util
-
-import (
-	"syscall"
-)
-
-func SetLimit() {
-	var rLimit syscall.Rlimit
-	if err := syscall.Getrlimit(syscall.RLIMIT_NOFILE, &rLimit); err != nil {
-		panic(err)
-	}
-	rLimit.Cur = rLimit.Max
-	if err := syscall.Setrlimit(syscall.RLIMIT_NOFILE, &rLimit); err != nil {
-		panic(err)
-	}
-}

demo/util/limit_windows.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package util
-
-func SetLimit() {
-}

demo/util/pprof.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package util
-
-import (
-	"fmt"
-	"net/http"
-	_ "net/http/pprof"
-)
-
-func Profiling(port int) {
-	go func() {
-		http.ListenAndServe(fmt.Sprintf(":%d", port), nil)
-	}()
-}

demo/util/signals.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package util
-
-import (
-	"os"
-	"os/signal"
-	"syscall"
-)
-
-type Closer interface {
-	Close()
-}
-
-func WaitCloseSignals(closer Closer) {
-	signals := make(chan os.Signal, 1)
-	signal.Notify(signals, os.Interrupt, syscall.SIGQUIT, syscall.SIGTERM, syscall.SIGINT)
-	<-signals
-	closer.Close()
-}

getty.go

@@ -18,7 +18,7 @@
 package getty
 
 import (
-	gxsync "github.com/dubbogo/gost/sync"
+	gxsync "github.com/adamweixuan/gostnops/sync"
 
 	perrors "github.com/pkg/errors"
 )

go.mod

-module github.com/apache/dubbo-getty
+module github.com/adamweixuan/getty
 
-go 1.14
+go 1.17
 
 require (
-	github.com/dubbogo/gost v1.11.19
-	github.com/golang/snappy v0.0.1
+	github.com/adamweixuan/gostnops v1.11.20-0.20211029124314-3f0589fceea6
+	github.com/golang/snappy v0.0.4
 	github.com/gorilla/websocket v1.4.2
-	github.com/montanaflynn/stats v0.6.6
 	github.com/pkg/errors v0.9.1
-	github.com/stretchr/testify v1.7.0
 	go.uber.org/atomic v1.9.0
-	go.uber.org/zap v1.16.0
+	go.uber.org/zap v1.19.1
 )
+
+require go.uber.org/multierr v1.6.0 // indirect

options.go

@@ -18,7 +18,7 @@
 package getty
 
 import (
-	gxsync "github.com/dubbogo/gost/sync"
+	gxsync "github.com/adamweixuan/gostnops/sync"
 )
 
 type ServerOption func(*ServerOptions)

options_test.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package getty
-
-import (
-	"testing"
-)
-
-import (
-	"github.com/stretchr/testify/assert"
-)
-
-func TestClientOptions(t *testing.T) {
-	addr := "127.0.0.1:0"
-	file := ""
-	clt := newClient(TCP_CLIENT,
-		WithServerAddress(addr),
-		WithReconnectInterval(5e8),
-		WithConnectionNumber(1),
-		WithRootCertificateFile(file),
-	)
-	assert.NotNil(t, clt)
-	assert.Equal(t, clt.endPointType, TCP_CLIENT)
-	assert.True(t, clt.endPointType > 0)
-	assert.NotNil(t, clt.done)
-	assert.NotNil(t, clt.ssMap)
-	assert.Equal(t, clt.addr, addr)
-	assert.NotNil(t, clt.reconnectInterval)
-	assert.NotNil(t, clt.cert)
-	assert.Equal(t, clt.number, 1)
-}
-
-func TestServerOptions(t *testing.T) {
-	addr := "127.0.0.1:0"
-	path := "/test"
-	cert := ""
-	key := "test"
-	srv := newServer(TCP_SERVER,
-		WithLocalAddress(addr),
-		WithWebsocketServerPath(path),
-		WithWebsocketServerCert(cert),
-		WithWebsocketServerPrivateKey(key),
-		WithWebsocketServerRootCert(cert),
-	)
-	assert.NotNil(t, srv)
-	assert.Equal(t, srv.endPointType, TCP_SERVER)
-	assert.True(t, srv.endPointType > 0)
-	assert.NotNil(t, srv.done)
-	assert.Equal(t, srv.addr, addr)
-	assert.Equal(t, srv.path, path)
-	assert.Equal(t, srv.cert, cert)
-	assert.Equal(t, srv.privateKey, key)
-	assert.Equal(t, srv.caCert, cert)
-}

server.go

@@ -31,9 +31,9 @@ import (
 )
 
 import (
-	gxnet "github.com/dubbogo/gost/net"
-	gxsync "github.com/dubbogo/gost/sync"
-	gxtime "github.com/dubbogo/gost/time"
+	gxnet "github.com/adamweixuan/gostnops/net"
+	gxsync "github.com/adamweixuan/gostnops/sync"
+	gxtime "github.com/adamweixuan/gostnops/time"
 
 	"github.com/gorilla/websocket"
 

server_test.go

-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package getty
-
-import (
-	"path/filepath"
-	"testing"
-	"time"
-)
-
-import (
-	"github.com/stretchr/testify/assert"
-)
-
-func testTCPServer(t *testing.T, address string) {
-	var (
-		server           *server
-		serverMsgHandler MessageHandler
-	)
-
-	func() {
-		server = newServer(
-			TCP_SERVER,
-			WithLocalAddress(address),
-		)
-		newServerSession := func(session Session) error {
-			return newSessionCallback(session, &serverMsgHandler)
-		}
-		server.RunEventLoop(newServerSession)
-		assert.True(t, server.ID() > 0)
-		assert.True(t, server.EndPointType() == TCP_SERVER)
-		assert.NotNil(t, server.streamListener)
-	}()
-	time.Sleep(500e6)
-
-	addr := server.streamListener.Addr().String()
-	t.Logf("@address:%s, tcp server addr: %v", address, addr)
-	clt := newClient(TCP_CLIENT,
-		WithServerAddress(addr),
-		WithReconnectInterval(5e8),
-		WithConnectionNumber(1),
-	)
-	assert.NotNil(t, clt)
-	assert.True(t, clt.ID() > 0)
-	assert.Equal(t, clt.endPointType, TCP_CLIENT)
-
-	var msgHandler MessageHandler
-	cb := func(session Session) error {
-		return newSessionCallback(session, &msgHandler)
-	}
-
-	clt.RunEventLoop(cb)
-	time.Sleep(1e9)
-
-	assert.Equal(t, 1, msgHandler.SessionNumber())
-	clt.Close()
-	assert.True(t, clt.IsClosed())
-
-	server.Close()
-	assert.True(t, server.IsClosed())
-}
-
-func testTCPTlsServer(t *testing.T, address string) {
-	var (
-		server           *server
-		serverMsgHandler MessageHandler
-	)
-	serverPemPath, _ := filepath.Abs("./demo/hello/tls/certs/server0.pem")
-	serverKeyPath, _ := filepath.Abs("./demo/hello/tls/certs/server0.key")
-	caPemPath, _ := filepath.Abs("./demo/hello/tls/certs/ca.pem")
-
-	configBuilder := &ServerTlsConfigBuilder{
-		ServerKeyCertChainPath:        serverPemPath,
-		ServerPrivateKeyPath:          serverKeyPath,
-		ServerTrustCertCollectionPath: caPemPath,
-	}
-
-	func() {
-		server = newServer(
-			TCP_SERVER,
-			WithLocalAddress(address),
-			WithServerSslEnabled(true),
-			WithServerTlsConfigBuilder(configBuilder),
-		)
-		newServerSession := func(session Session) error {
-			return newSessionCallback(session, &serverMsgHandler)
-		}
-		server.RunEventLoop(newServerSession)
-		assert.True(t, server.ID() > 0)
-		assert.True(t, server.EndPointType() == TCP_SERVER)
-		assert.NotNil(t, server.streamListener)
-	}()
-	time.Sleep(500e6)
-
-	addr := server.streamListener.Addr().String()
-	t.Logf("@address:%s, tcp server addr: %v", address, addr)
-	keyPath, _ := filepath.Abs("./demo/hello/tls/certs/ca.key")
-	clientCaPemPath, _ := filepath.Abs("./demo/hello/tls/certs/ca.pem")
-
-	clientConfig := &ClientTlsConfigBuilder{
-		ClientTrustCertCollectionPath: clientCaPemPath,
-		ClientPrivateKeyPath:          keyPath,
-	}
-
-	clt := newClient(TCP_CLIENT,
-		WithServerAddress(addr),
-		WithReconnectInterval(5e8),
-		WithConnectionNumber(1),
-		WithClientTlsConfigBuilder(clientConfig),
-	)
-	assert.NotNil(t, clt)
-	assert.True(t, clt.ID() > 0)
-	assert.Equal(t, clt.endPointType, TCP_CLIENT)
-
-	var msgHandler MessageHandler
-	cb := func(session Session) error {
-		return newSessionCallback(session, &msgHandler)
-	}
-
-	clt.RunEventLoop(cb)
-	time.Sleep(1e9)
-
-	assert.Equal(t, 1, msgHandler.SessionNumber())
-	clt.Close()
-	assert.True(t, clt.IsClosed())
-
-	server.Close()
-	assert.True(t, server.IsClosed())
-}
-
-func testUDPServer(t *testing.T, address string) {
-	var (
-		server           *server
-		serverMsgHandler MessageHandler
-	)
-	func() {
-		server = newServer(
-			UDP_ENDPOINT,
-			WithLocalAddress(address),
-		)
-		newServerSession := func(session Session) error {
-			return newSessionCallback(session, &serverMsgHandler)
-		}
-		server.RunEventLoop(newServerSession)
-		assert.True(t, server.ID() > 0)
-		assert.True(t, server.EndPointType() == UDP_ENDPOINT)
-		assert.NotNil(t, server.pktListener)
-	}()
-	time.Sleep(500e6)
-
-	addr := server.pktListener.LocalAddr().String()
-	t.Logf("@address:%s, udp server addr: %v", address, addr)
-}
-
-func TestServer(t *testing.T) {
-	var addr string
-
-	testTCPServer(t, addr)
-	testUDPServer(t, addr)
-
-	addr = "127.0.0.1:0"
-	testTCPServer(t, addr)
-	testUDPServer(t, addr)
-
-	addr = "127.0.0.1"
-	testTCPServer(t, addr)
-	testUDPServer(t, addr)
-	addr = "127.0.0.9999"
-	testTCPTlsServer(t, addr)
-}

session.go

@@ -29,9 +29,9 @@ import (
 )
 
 import (
-	gxbytes "github.com/dubbogo/gost/bytes"
-	gxcontext "github.com/dubbogo/gost/context"
-	gxtime "github.com/dubbogo/gost/time"
+	gxbytes "github.com/adamweixuan/gostnops/bytes"
+	gxcontext "github.com/adamweixuan/gostnops/context"
+	gxtime "github.com/adamweixuan/gostnops/time"
 
 	"github.com/gorilla/websocket"
 
@@ -628,7 +628,7 @@ func (s *session) handleTCPPackage() error {
 					err = nil
 					exit = true
 					if bufLen != 0 {
-						// as https://github.com/apache/dubbo-getty/issues/77#issuecomment-939652203
+						// as https://github.com/adamweixuan/getty/issues/77#issuecomment-939652203
 						// this branch is impossible. Even if it happens, the bufLen will be zero and the error
 						// is io.EOF when getty continues to read the socket.
 						exit = false