1

common/socket/ServerEvent.go

@@ -27,8 +27,14 @@ func (s *Server) Boot(serverid, port uint16) error {
 		gnet.WithMulticore(true),
 		gnet.WithTicker(true),
 
-		// gnet.WithReusePort(true),
-		// gnet.WithReuseAddr(true),
+		// 其他调优配置↓
+		gnet.WithTCPNoDelay(gnet.TCPNoDelay), // 禁用Nagle算法（降低延迟，适合小数据包场景）
+		gnet.WithReusePort(true),             // 开启SO_REUSEPORT（多核下提升并发）
+		gnet.WithReadBufferCap(1024*64),      // 读缓冲区64KB（根据业务调整，默认太小）
+		gnet.WithWriteBufferCap(1024*64),     // 写缓冲区64KB
+
+		gnet.WithLockOSThread(true), // 绑定goroutine到OS线程（减少上下文切换）
+
 		gnet.WithSocketRecvBuffer(s.bufferSize))
 	if err != nil {
 		panic(err)

common/socket/ServerOption.go

@@ -24,9 +24,9 @@ type Server struct {
 	handler    Handler
 	discorse   bool
 	quit       bool
-	batchRead  int
-	serverid   uint16
-	port       uint16
+	//	batchRead  int
+	serverid uint16
+	port     uint16
 }
 
 type Option func(*Server)
@@ -38,9 +38,9 @@ func NewServer(options ...Option) *Server {
 		//	handler:    handler.NewTomeeHandler(),   //请求返回
 		codec:      codec.NewTomeeSocketCodec(), //默认解码器 len+pack
 		workerPool: goroutine.Default(),
-		bufferSize: 4096, //默认缓冲区大小
+		bufferSize: 40960, //默认缓冲区大小
 		multicore:  true,
-		batchRead:  8,
+		//batchRead:  8,
 		//discorse:   true,
 	}
 	for _, option := range options {