Service templates support SO_REUSEPORT option

Author: zhengshuxin

config.go

@@ -11,29 +11,30 @@ import (
 	"strings"
 )
 
-const Version string = "1.0.8"
+const Version string = "1.0.9"
 
 type Config struct {
 	Entries map[string]string
 }
 
 // from configure file of the app
 var (
-	AppConf         *Config
-	AppService       string
-	AppLogPath       string
-	AppOwner         string
-	AppArgs          string
-	AppRootDir       string
+	AppConf        *Config
+	AppService     string
+	AppLogPath     string
+	AppOwner       string
+	AppArgs        string
+	AppRootDir     string
 	AppUseLimit    = 0
 	AppIdleLimit   = 0
+	AppReusePort   = false
 	AppQuickAbort  = false
 	AppWaitLimit   = 10
 	AppAccessAllow = "all"
 	Appthreads     = 0
 
-	TlsCertFile      string
-	TlsKeyFile       string
+	TlsCertFile string
+	TlsKeyFile  string
 )
 
 func loadConf(confPath string) {
@@ -54,6 +55,7 @@ func loadConf(confPath string) {
 	AppService = AppConf.GetString("master_service")
 	AppOwner = AppConf.GetString("master_owner")
 	AppArgs = AppConf.GetString("master_args")
+	AppReusePort = AppConf.GetBool("master_reuseport")
 
 	AppRootDir = AppConf.GetString("app_queue_dir")
 	AppUseLimit = AppConf.GetInt("app_use_limit")

examples/gin-server/gin-server.cf

@@ -10,7 +10,21 @@ service gin-server {
 #	当子进程异常退出时，如果该值非空，则将子进程异常退出的消息通知该服务
 #	master_notify_addr = 127.0.0.1:5801
 #	邮件通知接收者
-#	master_notify_recipients = [email protected]
+#	master_notify_recipients = [email protected]
+
+#	停止子进程时是否采用强行停止的方式(即给子进程发送 SIGTERM 信号)
+	master_stop_kill = false
+#	当 master_stop_kill 为 true 时，该配置决定是否要等待子进程退出
+	master_stop_wait = false
+
+#	当系统支持 SO_REUSEPORT 时，是否启用该功能
+	master_reuseport = no
+#	当启用 SO_REUSEPORT 时(即 master_reuseport=yes 时), 是否需要 acl_master
+#	也监听该地址, 对于使用旧版 acl(< 3.5.3-17) 编写的服务, 必须将此项设为
+#	yes, 即: master_reuseport_listen = yes; 对于使用 acl 版本 >= 3.5.3-17
+#	编写的服务需设置为 no; 当 master_reuseport=no时,该项设置将被忽略; 当未
+#	设置此项时内部缺省值为 yes. 以便使 acl_master 保持对于旧版服务的兼容性.
+	master_reuseport_listen = no
 
 #	是否允许延迟接受客户端连接，如果为0则表示关闭该功能，如果大于0则表示打开此功能
 #	并且此值代表延迟接受连接的超时值，超过此值时如果客户端依然没有发来数据，则操作

examples/go-echod/go-echod.cf

@@ -13,7 +13,21 @@ service echo {
 #	当子进程异常退出时，如果该值非空，则将子进程异常退出的消息通知该服务
 #	master_notify_addr = 127.0.0.1:5801
 #	邮件通知接收者
-#	master_notify_recipients = [email protected]
+#	master_notify_recipients = [email protected]
+
+#	停止子进程时是否采用强行停止的方式(即给子进程发送 SIGTERM 信号)
+	master_stop_kill = false
+#	当 master_stop_kill 为 true 时，该配置决定是否要等待子进程退出
+	master_stop_wait = false
+
+#	当系统支持 SO_REUSEPORT 时，是否启用该功能
+	master_reuseport = no
+#	当启用 SO_REUSEPORT 时(即 master_reuseport=yes 时), 是否需要 acl_master
+#	也监听该地址, 对于使用旧版 acl(< 3.5.3-17) 编写的服务, 必须将此项设为
+#	yes, 即: master_reuseport_listen = yes; 对于使用 acl 版本 >= 3.5.3-17
+#	编写的服务需设置为 no; 当 master_reuseport=no时,该项设置将被忽略; 当未
+#	设置此项时内部缺省值为 yes. 以便使 acl_master 保持对于旧版服务的兼容性.
+	master_reuseport_listen = no
 
 #	是否允许延迟接受客户端连接，如果为0则表示关闭该功能，如果大于0则表示打开此功能
 #	并且此值代表延迟接受连接的超时值，超过此值时如果客户端依然没有发来数据，则操作

examples/go-httpd/go-httpd.cf

@@ -10,7 +10,21 @@ service go-httpd {
 #	当子进程异常退出时，如果该值非空，则将子进程异常退出的消息通知该服务
 #	master_notify_addr = 127.0.0.1:5801
 #	邮件通知接收者
-#	master_notify_recipients = [email protected]
+#	master_notify_recipients = [email protected]
+
+#	停止子进程时是否采用强行停止的方式(即给子进程发送 SIGTERM 信号)
+	master_stop_kill = false
+#	当 master_stop_kill 为 true 时，该配置决定是否要等待子进程退出
+	master_stop_wait = false
+
+#	当系统支持 SO_REUSEPORT 时，是否启用该功能
+	master_reuseport = no
+#	当启用 SO_REUSEPORT 时(即 master_reuseport=yes 时), 是否需要 acl_master
+#	也监听该地址, 对于使用旧版 acl(< 3.5.3-17) 编写的服务, 必须将此项设为
+#	yes, 即: master_reuseport_listen = yes; 对于使用 acl 版本 >= 3.5.3-17
+#	编写的服务需设置为 no; 当 master_reuseport=no时,该项设置将被忽略; 当未
+#	设置此项时内部缺省值为 yes. 以便使 acl_master 保持对于旧版服务的兼容性.
+	master_reuseport_listen = no
 
 #	是否允许延迟接受客户端连接，如果为0则表示关闭该功能，如果大于0则表示打开此功能
 #	并且此值代表延迟接受连接的超时值，超过此值时如果客户端依然没有发来数据，则操作

examples/grpc/grpc-server.cf

@@ -10,7 +10,21 @@ service grpc-server {
 #	当子进程异常退出时，如果该值非空，则将子进程异常退出的消息通知该服务
 #	master_notify_addr = 127.0.0.1:5801
 #	邮件通知接收者
-#	master_notify_recipients = [email protected]
+#	master_notify_recipients = [email protected]
+
+#	停止子进程时是否采用强行停止的方式(即给子进程发送 SIGTERM 信号)
+	master_stop_kill = false
+#	当 master_stop_kill 为 true 时，该配置决定是否要等待子进程退出
+	master_stop_wait = false
+
+#	当系统支持 SO_REUSEPORT 时，是否启用该功能
+	master_reuseport = no
+#	当启用 SO_REUSEPORT 时(即 master_reuseport=yes 时), 是否需要 acl_master
+#	也监听该地址, 对于使用旧版 acl(< 3.5.3-17) 编写的服务, 必须将此项设为
+#	yes, 即: master_reuseport_listen = yes; 对于使用 acl 版本 >= 3.5.3-17
+#	编写的服务需设置为 no; 当 master_reuseport=no时,该项设置将被忽略; 当未
+#	设置此项时内部缺省值为 yes. 以便使 acl_master 保持对于旧版服务的兼容性.
+	master_reuseport_listen = no
 
 #	是否允许延迟接受客户端连接，如果为0则表示关闭该功能，如果大于0则表示打开此功能
 #	并且此值代表延迟接受连接的超时值，超过此值时如果客户端依然没有发来数据，则操作

examples/httpd-handler/httpd-handler.cf

@@ -10,7 +10,21 @@ service httpd-handler {
 #	当子进程异常退出时，如果该值非空，则将子进程异常退出的消息通知该服务
 #	master_notify_addr = 127.0.0.1:5801
 #	邮件通知接收者
-#	master_notify_recipients = [email protected]
+#	master_notify_recipients = [email protected]
+
+#	停止子进程时是否采用强行停止的方式(即给子进程发送 SIGTERM 信号)
+	master_stop_kill = false
+#	当 master_stop_kill 为 true 时，该配置决定是否要等待子进程退出
+	master_stop_wait = false
+
+#	当系统支持 SO_REUSEPORT 时，是否启用该功能
+	master_reuseport = no
+#	当启用 SO_REUSEPORT 时(即 master_reuseport=yes 时), 是否需要 acl_master
+#	也监听该地址, 对于使用旧版 acl(< 3.5.3-17) 编写的服务, 必须将此项设为
+#	yes, 即: master_reuseport_listen = yes; 对于使用 acl 版本 >= 3.5.3-17
+#	编写的服务需设置为 no; 当 master_reuseport=no时,该项设置将被忽略; 当未
+#	设置此项时内部缺省值为 yes. 以便使 acl_master 保持对于旧版服务的兼容性.
+	master_reuseport_listen = no
 
 #	是否允许延迟接受客户端连接，如果为0则表示关闭该功能，如果大于0则表示打开此功能
 #	并且此值代表延迟接受连接的超时值，超过此值时如果客户端依然没有发来数据，则操作

service.go

@@ -223,6 +223,7 @@ func GetListenersByAddrs(addrs string) ([]net.Listener, error) {
 
 	addrs = strings.Replace(addrs, " ", "", -1)
 	addrs = strings.Replace(addrs, ",", ";", -1)
+	addrs = strings.Replace(addrs, "|", ":", -1)
 	tokens := strings.Split(addrs, ";")
 
 	cfg := net.ListenConfig{
@@ -309,7 +310,11 @@ func ServiceInit(addrs string, stopHandler func(bool)) ([]net.Listener, error) {
 
 	if !Alone && len(sockType) > 0 {
 		var err error
-		listeners, err = GetListeners()
+		if AppReusePort && len(AppService) > 0 {
+			listeners, err = GetListenersByAddrs(AppService)
+		} else {
+			listeners, err = GetListeners()
+		}
 		if err != nil {
 			log.Println("GetListeners failed", err)
 			return nil, err