Bump golang.org/x/crypto from 0.26.0 to 0.45.0

Bumps [golang.org/x/crypto](https://github.com/golang/crypto) from 0.26.0 to 0.45.0. - [Commits](https://github.com/golang/crypto/compare/v0.26.0...v0.45.0) --- updated-dependencies: - dependency-name: golang.org/x/crypto dependency-version: 0.45.0 dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com>
2026-02-13 07:04:44 +08:00 · 2025-11-20 00:58:12 +00:00
11 changed files with 115 additions and 351 deletions
--- a/README.md
+++ b/README.md
@@ -80,22 +80,8 @@ Etcd方式示例：
      "DialTimeoutMillisecond": 3000,
      "EtcdList": [
        {
-          "LocalNetworkName": "network_Area1",
-          "Endpoints": ["http://127.0.0.1:12379"],
-          "UserName": "",
-          "Password": "",
-          "Cert": "",
-          "CertKey": "",
-          "Ca": ""
-        },
-        {
-          "NeighborNetworkName": ["network_Area2"],
-          "Endpoints": ["http://127.0.0.1:12379"],
-          "UserName": "",
-          "Password": "",
-          "Cert": "",
-          "CertKey": "",
-          "Ca": ""
+          "NetworkName": ["network1"],
+          "Endpoints": ["http://192.168.13.24:12379"]
        }
      ]
    }
@@ -106,16 +92,12 @@ TTLSecond：表示健康检查TTL失效时间10秒

 DialTimeoutMillisecond: 与etcd连接超时时间

-EtcdList：Etcd列表，可以多个Etcd服务器连接（注意：列表中必需有一个LocalNetworkName项，表示当前所有的Node归属当前网络名为network_Area1）Node下所有的服务会往network_Area1中注册。监听该网络的结点可以发现该网络中的Service。本地网络会默认监听本地网络中所有的服务。
+EtcdList：Etcd列表，可以多个Etcd服务器连接

-NeighborNetworkName：表示监听的邻居网络名，可以发现该网络中所有Service
+NetworkName：所在的网络名称，可以配置多个。node会往对应的网络名称中注册、监听发现Service。NetworkName也起到发现隔离的作用。

 Endpoints：Etcd服务器地址

-
-
-
-
 Origin方式示例：

 ```json
@@ -123,15 +105,10 @@ Origin方式示例：
  "Discovery": {
    "Origin":{
      "TTLSecond": 10,
-     "LocalMasterNodeId": "bot",
      "MasterNodeList": [
        {
-          "NodeId": "bot",
-          "ListenAddr": "127.0.0.1:11001"
-        },
-        {
-          "NodeId": "mp1server",
-          "ListenAddr": "127.0.0.1:11000"
+          "NodeId": "test_1",
+          "ListenAddr": "127.0.0.1:8801"
        }
      ]
    }
@@ -141,12 +118,8 @@ Origin方式示例：

 TTLSecond：表示健康检查TTL失效时间10秒

-LocalMasterNodeId：本地所有的Node归属当前Master NodeId。归属当前的所有的Node会往该Master Node中注册服务。MasterNode会自动同步给所有的监听结点。本地Node会默认监听本地Master Node中所有的服务。注意LocalMasterNodeId配置的NodeId要在MasterNodeList列表中。
-
 MasterNodeList：指定哪些Node为服务发现Master结点，需要配置NodeId与ListenAddr，注意它们要与实际的Node配置一致。

-
-
 ### RpcMode部分

 默认模式
@@ -974,45 +947,20 @@ origin引擎默认使用读取所有结点配置的进行确认结点有哪些Se
        "Private": false,
        "remark": "//以_打头的，表示只在本机进程，不对整个子网开发",
        "ServiceList": ["_TestService1", "TestService9", "TestService10"],
-        "AllowDiscovery": [
+        "DiscoveryService": [
            {
                "MasterNodeId": "nodeid_1",
-                "NetworkName":"networkname1",
-                "NodeIdList":[".*server"],
-                "ServiceList": ["TestService8"]
+                "NetworkName":"networkname1"
+                "DiscoveryService": ["TestService8"]
            }
        ]
    }]
 }
 ```

-以上，如果是使用Etcd发现模式，则表示可以发现网络名networkname1，NodeId为server结尾，服务名为TestService8的服务。
-
-AllowDiscovery：可以配置发现的规则，如果只配置MasterNodeId或NetworkName时(如果使用Etcd则只配置NetworkName,Origin则只配置MasterNodeId)，则会筛选指定网络的所有服务，如下：
-
-```
-"AllowDiscovery": [
-            {
-                "NetworkName":"networkname1",
-            }
-        ]
-```
-
-则以上，只匹配networkname1网络名的所有服务，支持正则表达式，例如可以配置为"NetworkName":".*name1",则可以发现网络名为name1结尾的所有服务。
-
-如果只发现NodeId为server结尾的所有服务，可以使用以下配置方式：
-
-```
-"AllowDiscovery": [
-            {
-                "NodeIdList":[".*server"]
-            }
-        ]
-```
-
-筛选服务也是同上。也可以组合配置NetworkName和NodeIdList配置。
-
+DiscoveryService：在当前nodeid为nodeid_test的结点中，只发现 MasterNodeId为nodeid_1或NetworkName为networkname1网络中的TestService8服务。

+**注意**：MasterNodeId与NetworkName只配置一个，分别在模式为origin或者etcd服务发现类型时。

 第八章：HttpService使用
 -----------------------
--- a/cluster/cluster.go
+++ b/cluster/cluster.go
@@ -7,8 +7,6 @@ import (
 	"strings"
 	"sync"

-	"regexp"
-
 	"github.com/duanhf2012/origin/v2/event"
 	"github.com/duanhf2012/origin/v2/log"
 	"github.com/duanhf2012/origin/v2/rpc"
@@ -26,23 +24,21 @@ const (
 	Discard NodeStatus = 1 //丢弃
 )

-// AllowDiscovery 允许发现的网络服务
-type AllowDiscovery struct {
-	MasterNodeId string   // 支持正则表达式
-	NetworkName  string   // 支持正则表达式
-	NodeIdList   []string // 支持正则表达式
-	ServiceList  []string
+type DiscoveryService struct {
+	MasterNodeId string   //要筛选的主结点Id，如果不配置或者配置成0，表示针对所有的主结点
+	NetworkName  string   //如果是etcd，指定要筛选的网络名中的服务，不配置，表示所有的网络
+	ServiceList  []string //只发现的服务列表
 }

 type NodeInfo struct {
 	NodeId            string
 	Private           bool
 	ListenAddr        string
-	MaxRpcParamLen    uint32           //最大Rpc参数长度
-	CompressBytesLen  int              //超过字节进行压缩的长度
-	ServiceList       []string         //所有的有序服务列表
-	PublicServiceList []string         //对外公开的服务列表
-	AllowDiscovery    []AllowDiscovery //允许发现的网络服务
+	MaxRpcParamLen    uint32             //最大Rpc参数长度
+	CompressBytesLen  int                //超过字节进行压缩的长度
+	ServiceList       []string           //所有的有序服务列表
+	PublicServiceList []string           //对外公开的服务列表
+	DiscoveryService  []DiscoveryService //筛选发现的服务，如果不配置，不进行筛选
 	status            NodeStatus
 	Retire            bool
 }
@@ -227,9 +223,9 @@ func (cls *Cluster) serviceDiscoverySetNodeInfo(nodeInfo *NodeInfo) {
 	}
 	cls.mapRpc[nodeInfo.NodeId] = &rpcInfo
 	if cls.IsNatsMode() == true || cls.discoveryInfo.discoveryType != OriginType {
-		log.Info("Discovery node and new rpc client", log.String("NodeId", nodeInfo.NodeId), log.Any("services:", nodeInfo.PublicServiceList), log.Bool("Retire", nodeInfo.Retire))
+		log.Info("Discovery nodeId and new rpc client", log.String("NodeId", nodeInfo.NodeId), log.Any("services:", nodeInfo.PublicServiceList), log.Bool("Retire", nodeInfo.Retire))
 	} else {
-		log.Info("Discovery node and new rpc client", log.String("NodeId", nodeInfo.NodeId), log.Any("services:", nodeInfo.PublicServiceList), log.Bool("Retire", nodeInfo.Retire), log.String("nodeListenAddr", nodeInfo.ListenAddr))
+		log.Info("Discovery nodeId and new rpc client", log.String("NodeId", nodeInfo.NodeId), log.Any("services:", nodeInfo.PublicServiceList), log.Bool("Retire", nodeInfo.Retire), log.String("nodeListenAddr", nodeInfo.ListenAddr))
 	}
 }

@@ -466,76 +462,28 @@ func (cls *Cluster) GetNodeInfo(nodeId string) (NodeInfo, bool) {
 	return nodeInfo.nodeInfo, true
 }

-func (cls *Cluster) CanDiscoveryService(fromNetworkName string, fromMasterNodeId string, fromNodeId string, serviceName string) bool {
+func (cls *Cluster) CanDiscoveryService(fromMasterNodeId string, serviceName string) bool {
 	canDiscovery := true
-	// 筛选允许的服务
+
 	splitServiceName := strings.Split(serviceName, ":")
 	if len(splitServiceName) == 2 {
 		serviceName = splitServiceName[0]
 	}

-	// 先筛选允许的网络,有配置才会检测
-	if len(cls.GetLocalNodeInfo().AllowDiscovery) > 0 {
-		allowNetwork := false
-		for i := 0; i < len(cls.GetLocalNodeInfo().AllowDiscovery); i++ {
-			masterNodeId := cls.GetLocalNodeInfo().AllowDiscovery[i].MasterNodeId
-			networkName := cls.GetLocalNodeInfo().AllowDiscovery[i].NetworkName
-			nodeIdList := cls.GetLocalNodeInfo().AllowDiscovery[i].NodeIdList
-			serviceList := cls.GetLocalNodeInfo().AllowDiscovery[i].ServiceList
-
-			// 如果配置了网络及Master结点，则匹配之
-			if fromNetworkName != "" {
-				matchNetWork, _ := regexp.MatchString(networkName, fromNetworkName)
-				if !matchNetWork {
-					continue
-				}
-			} else if fromMasterNodeId != "" {
-				matchMasterNode, _ := regexp.MatchString(masterNodeId, fromMasterNodeId)
-				if !matchMasterNode {
-					continue
-				}
-			}
-
-			// 如果配置了
-			if len(nodeIdList) > 0 {
-				hasNode := false
-				for _, nodeId := range nodeIdList {
-					matchNodeId, _ := regexp.MatchString(nodeId, fromNodeId)
-					if !matchNodeId {
-						continue
-					}
-					hasNode = true
-					break
-				}
-
-				if !hasNode {
-					continue
-				}
-			}
-
-			// 如果配置了服务，则匹配之
-			if len(serviceList) > 0 {
-				hasService := false
-				for _, service := range serviceList {
-					// service按正则表达式匹配serviceName
-					matched, _ := regexp.MatchString(service, serviceName)
-					if matched {
-						hasService = true
-						break
-					}
-				}
-
-				if !hasService {
-					continue
-				}
-			}
-
-			allowNetwork = true
-			break
+	for i := 0; i < len(cls.GetLocalNodeInfo().DiscoveryService); i++ {
+		masterNodeId := cls.GetLocalNodeInfo().DiscoveryService[i].MasterNodeId
+		//无效的配置，则跳过
+		if masterNodeId == rpc.NodeIdNull && len(cls.GetLocalNodeInfo().DiscoveryService[i].ServiceList) == 0 {
+			continue
 		}

-		if !allowNetwork {
-			return false
+		canDiscovery = false
+		if masterNodeId == fromMasterNodeId || masterNodeId == rpc.NodeIdNull {
+			for _, discoveryService := range cls.GetLocalNodeInfo().DiscoveryService[i].ServiceList {
+				if discoveryService == serviceName {
+					return true
+				}
+			}
 		}
 	}

--- a/cluster/etcddiscovery.go
+++ b/cluster/etcddiscovery.go
@@ -6,12 +6,6 @@ import (
 	"crypto/x509"
 	"errors"
 	"fmt"
-	"os"
-	"path"
-	"strings"
-	"sync/atomic"
-	"time"
-
 	"github.com/duanhf2012/origin/v2/event"
 	"github.com/duanhf2012/origin/v2/log"
 	"github.com/duanhf2012/origin/v2/rpc"
@@ -20,15 +14,19 @@ import (
 	"go.etcd.io/etcd/api/v3/mvccpb"
 	"go.etcd.io/etcd/client/v3"
 	"google.golang.org/protobuf/proto"
+	"os"
+	"path"
+	"strings"
+	"sync/atomic"
+	"time"
 )

 const originDir = "/origin"

 type etcdClientInfo struct {
-	isLocalNetwork bool
-	watchKeys      []string
-	leaseID        clientv3.LeaseID
-	keepAliveChan  <-chan *clientv3.LeaseKeepAliveResponse
+	watchKeys     []string
+	leaseID       clientv3.LeaseID
+	keepAliveChan <-chan *clientv3.LeaseKeepAliveResponse
 }

 type EtcdDiscoveryService struct {
@@ -95,7 +93,6 @@ func (ed *EtcdDiscoveryService) OnInit() error {
 		return errors.New("etcd discovery config is nil.")
 	}

-	var hasLocalNetwork bool
 	for i := 0; i < len(etcdDiscoveryCfg.EtcdList); i++ {
 		var client *clientv3.Client
 		var tlsConfig *tls.Config
@@ -144,25 +141,13 @@ func (ed *EtcdDiscoveryService) OnInit() error {
 		}

 		ec := &etcdClientInfo{}
-
-		if etcdDiscoveryCfg.EtcdList[i].LocalNetworkName != "" {
-			hasLocalNetwork = true
-			ec.isLocalNetwork = true
-			ec.watchKeys = append(ec.watchKeys, fmt.Sprintf("%s/%s", originDir, etcdDiscoveryCfg.EtcdList[i].LocalNetworkName))
-		} else {
-			ec.isLocalNetwork = false
-			for _, networkName := range etcdDiscoveryCfg.EtcdList[i].NeighborNetworkName {
-				ec.watchKeys = append(ec.watchKeys, fmt.Sprintf("%s/%s", originDir, networkName))
-			}
+		for _, networkName := range etcdDiscoveryCfg.EtcdList[i].NetworkName {
+			ec.watchKeys = append(ec.watchKeys, fmt.Sprintf("%s/%s", originDir, networkName))
 		}

 		ed.mapClient[client] = ec
 	}

-	if !hasLocalNetwork {
-		return errors.New("etcd discovery init fail,cannot find local network")
-	}
-
 	return nil
 }

@@ -182,18 +167,14 @@ func (ed *EtcdDiscoveryService) registerServiceByClient(client *clientv3.Client,
 	}

 	etcdClient.leaseID = resp.ID
-
-	// 注册服务节点到 etcd,LocalNetwork时才会注册，且etcdClient.watchKeys必然>0
-	if len(etcdClient.watchKeys) != 1 {
-		log.Error("LocalNetwork watchkey is error")
-		return
-	}
-
-	_, err = client.Put(context.Background(), ed.getRegisterKey(etcdClient.watchKeys[0]), ed.byteLocalNodeInfo, clientv3.WithLease(resp.ID))
-	if err != nil {
-		log.Error("etcd Put fail", log.ErrorField("err", err))
-		ed.tryRegisterService(client, etcdClient)
-		return
+	for _, watchKey := range etcdClient.watchKeys {
+		// 注册服务节点到 etcd
+		_, err = client.Put(context.Background(), ed.getRegisterKey(watchKey), ed.byteLocalNodeInfo, clientv3.WithLease(resp.ID))
+		if err != nil {
+			log.Error("etcd Put fail", log.ErrorField("err", err))
+			ed.tryRegisterService(client, etcdClient)
+			return
+		}
 	}

 	etcdClient.keepAliveChan, err = client.KeepAlive(context.Background(), etcdClient.leaseID)
@@ -223,10 +204,6 @@ func (ed *EtcdDiscoveryService) tryRegisterService(client *clientv3.Client, etcd
 		return
 	}

-	if !etcdClient.isLocalNetwork {
-		return
-	}
-
 	ed.AfterFunc(time.Second*3, func(t *timer.Timer) {
 		ed.registerServiceByClient(client, etcdClient)
 	})
@@ -252,18 +229,13 @@ func (ed *EtcdDiscoveryService) tryLaterRetire() {
 func (ed *EtcdDiscoveryService) retire() error {
 	//从etcd中更新
 	for c, ec := range ed.mapClient {
-		if !ec.isLocalNetwork {
-			continue
-		}
-
-		if len(ec.watchKeys)!=1 {
-			log.Error("LocalNetwork watchkey is error")
-			continue
-		}
-		_, err := c.Put(context.Background(), ed.getRegisterKey(ec.watchKeys[0]), ed.byteLocalNodeInfo, clientv3.WithLease(ec.leaseID))
-		if err != nil {
-			log.Error("etcd Put fail", log.ErrorField("err", err))
-			return err
+		for _, watchKey := range ec.watchKeys {
+			// 注册服务节点到 etcd
+			_, err := c.Put(context.Background(), ed.getRegisterKey(watchKey), ed.byteLocalNodeInfo, clientv3.WithLease(ec.leaseID))
+			if err != nil {
+				log.Error("etcd Put fail", log.ErrorField("err", err))
+				return err
+			}
 		}
 	}

@@ -320,7 +292,7 @@ func (ed *EtcdDiscoveryService) setNodeInfo(networkName string, nodeInfo *rpc.No
 	//筛选关注的服务
 	var discoverServiceSlice = make([]string, 0, 24)
 	for _, pubService := range nodeInfo.PublicServiceList {
-		if cluster.CanDiscoveryService(networkName, "", nodeInfo.NodeId, pubService) == true {
+		if cluster.CanDiscoveryService(networkName, pubService) == true {
 			discoverServiceSlice = append(discoverServiceSlice, pubService)
 		}
 	}
@@ -531,16 +503,11 @@ func (ed *EtcdDiscoveryService) RPC_ServiceRecord(etcdServiceRecord *service.Etc

 	//写入到etcd中
 	for c, info := range ed.mapClient {
-		if !info.isLocalNetwork {
-			continue
-		}
-
-		if len(info.watchKeys)!=1 {
-					log.Error("")
-		}
-		if ed.getNetworkNameByWatchKey(info.watchKeys[0]) == etcdServiceRecord.NetworkName {
-			client = c
-			break
+		for _, watchKey := range info.watchKeys {
+			if ed.getNetworkNameByWatchKey(watchKey) == etcdServiceRecord.NetworkName {
+				client = c
+				break
+			}
 		}
 	}

--- a/cluster/origindiscovery.go
+++ b/cluster/origindiscovery.go
@@ -508,17 +508,11 @@ func (dc *OriginDiscoveryClient) regServiceDiscover(nodeId string) {
 	if nodeId == cluster.GetLocalNodeInfo().NodeId {
 		return
 	}
-
 	nodeInfo := cluster.getOriginMasterDiscoveryNodeInfo(nodeId)
 	if nodeInfo == nil {
 		return
 	}

-	// 只能往本地Master结点上注册
-	if !cluster.IsLocalMasterNodeId(nodeId) {
-		return
-	}
-
 	var req rpc.RegServiceDiscoverReq
 	req.NodeInfo = &rpc.NodeInfo{}
 	req.NodeInfo.NodeId = cluster.localNodeInfo.NodeId
@@ -554,7 +548,7 @@ func (dc *OriginDiscoveryClient) setNodeInfo(masterNodeId string, nodeInfo *rpc.
 	//筛选关注的服务
 	var discoverServiceSlice = make([]string, 0, 24)
 	for _, pubService := range nodeInfo.PublicServiceList {
-		if cluster.CanDiscoveryService("",masterNodeId, nodeInfo.NodeId,pubService) == true {
+		if cluster.CanDiscoveryService(masterNodeId, pubService) == true {
 			discoverServiceSlice = append(discoverServiceSlice, pubService)
 		}
 	}
@@ -623,22 +617,13 @@ func (cls *Cluster) IsOriginMasterDiscoveryNode(nodeId string) bool {
 	return cls.getOriginMasterDiscoveryNodeInfo(nodeId) != nil
 }

-func (cls *Cluster) IsLocalMasterNodeId(nodeId string) bool {
-	if cls.discoveryInfo.Origin == nil {
-		return false
-	}
-
-	return cls.discoveryInfo.Origin.LocalMasterNodeId == nodeId
-}
 func (cls *Cluster) getOriginMasterDiscoveryNodeInfo(nodeId string) *NodeInfo {
 	if cls.discoveryInfo.Origin == nil {
 		return nil
 	}

 	for i := 0; i < len(cls.discoveryInfo.Origin.MasterNodeList); i++ {
-
-
-		if cls.discoveryInfo.Origin.MasterNodeList[i].NodeId == nodeId  {
+		if cls.discoveryInfo.Origin.MasterNodeList[i].NodeId == nodeId {
 			return &cls.discoveryInfo.Origin.MasterNodeList[i]
 		}
 	}
--- a/cluster/parsecfg.go
+++ b/cluster/parsecfg.go
@@ -16,27 +16,27 @@ import (

 var json = jsoniter.ConfigCompatibleWithStandardLibrary

+
 type EtcdList struct {
-	LocalNetworkName    string // 如果配置，则为本地网络,必需配置一个本地网络
-	NeighborNetworkName []string
-	Endpoints           []string
-	UserName            string
-	Password            string
-	Cert                string
-	CertKey             string
-	Ca                  string
+	NetworkName []string
+	Endpoints   []string
+	UserName string
+	Password string
+	Cert string
+	CertKey string
+	Ca string
 }

 type EtcdDiscovery struct {
 	DialTimeoutMillisecond time.Duration
 	TTLSecond              int64
-	EtcdList               []EtcdList
+
+	EtcdList []EtcdList
 }

 type OriginDiscovery struct {
-	TTLSecond         int64
-	LocalMasterNodeId string
-	MasterNodeList    []NodeInfo
+	TTLSecond      int64
+	MasterNodeList []NodeInfo
 }

 type DiscoveryType int
@@ -72,7 +72,7 @@ type NodeInfoList struct {
 }

 func validConfigFile(f string) bool {
-	return strings.HasSuffix(f, ".json") || strings.HasSuffix(f, ".yml") || strings.HasSuffix(f, ".yaml")
+	return strings.HasSuffix(f, ".json")|| strings.HasSuffix(f, ".yml") || strings.HasSuffix(f, ".yaml")
 }

 func yamlToJson(data []byte, v interface{}) ([]byte, error) {
@@ -131,20 +131,21 @@ func (d *DiscoveryInfo) setEtcd(etcd *EtcdDiscovery) error {
 		return fmt.Errorf("repeat configuration of Discovery")
 	}

+	//Endpoints不允许重复
+	mapAddr := make(map[string]struct{})
 	for _, n := range etcd.EtcdList {
-		//networkName不允许重复
-		mapNetworkName := make(map[string]struct{})
-		if n.LocalNetworkName != "" {
-			if _, ok := mapNetworkName[n.LocalNetworkName]; ok == true {
-				return fmt.Errorf("etcd discovery config Etcd.EtcdList.LocalNetworkName %+v is repeat", n.LocalNetworkName)
+		for _, endPoint := range n.Endpoints {
+			if _, ok := mapAddr[endPoint]; ok == true {
+				return fmt.Errorf("etcd discovery config Etcd.EtcdList.Endpoints %+v is repeat", endPoint)
 			}
-			mapNetworkName[n.LocalNetworkName] = struct{}{}
-			continue
+			mapAddr[endPoint] = struct{}{}
 		}

-		for _, netName := range n.NeighborNetworkName {
+		//networkName不允许重复
+		mapNetworkName := make(map[string]struct{})
+		for _, netName := range n.NetworkName {
 			if _, ok := mapNetworkName[netName]; ok == true {
-				return fmt.Errorf("etcd discovery config Etcd.EtcdList.NetworkName %+v is repeat", netName)
+				return fmt.Errorf("etcd discovery config Etcd.EtcdList.NetworkName %+v is repeat", n.NetworkName)
 			}

 			mapNetworkName[netName] = struct{}{}
@@ -274,7 +275,7 @@ func (cls *Cluster) readLocalClusterConfig(nodeId string) (DiscoveryInfo, []Node
 	var rpcMode RpcMode

 	//读取任何文件,只读符合格式的配置,目录下的文件可以自定义分文件
-	err := filepath.Walk(configDir, func(path string, info fs.FileInfo, err error) error {
+	err := filepath.Walk(configDir, func(path string, info fs.FileInfo, err error)error {
 		if info.IsDir() {
 			return nil
 		}
@@ -339,7 +340,7 @@ func (cls *Cluster) readLocalService(localNodeId string) error {
 	nodeService := map[string]interface{}{}

 	//读取任何文件,只读符合格式的配置,目录下的文件可以自定义分文件
-	err := filepath.Walk(configDir, func(path string, info fs.FileInfo, err error) error {
+	err := filepath.Walk(configDir, func(path string, info fs.FileInfo, err error)error{
 		if info.IsDir() {
 			return nil
 		}
@@ -431,7 +432,7 @@ func (cls *Cluster) readLocalService(localNodeId string) error {
 	return nil
 }

-func (cls *Cluster) parseLocalCfg() error {
+func (cls *Cluster) parseLocalCfg() error{
 	rpcInfo := NodeRpcInfo{}
 	rpcInfo.nodeInfo = cls.localNodeInfo
 	rpcInfo.client = rpc.NewLClient(rpcInfo.nodeInfo.NodeId, &cls.callSet)
@@ -453,7 +454,7 @@ func (cls *Cluster) parseLocalCfg() error {
 			cls.mapServiceNode[serviceName] = make(map[string]struct{})
 		}

-		if _, ok := cls.mapServiceNode[serviceName][cls.localNodeInfo.NodeId]; ok {
+		if _,ok:=cls.mapServiceNode[serviceName][cls.localNodeInfo.NodeId];ok {
 			return fmt.Errorf("duplicate service %s is configured in node %s", serviceName, cls.localNodeInfo.NodeId)
 		}
 		cls.mapServiceNode[serviceName][cls.localNodeInfo.NodeId] = struct{}{}
--- a/go.mod
+++ b/go.mod
@@ -1,8 +1,6 @@
 module github.com/duanhf2012/origin/v2

-go 1.22
-
-toolchain go1.22.7
+go 1.24.0

 require (
 	github.com/IBM/sarama v1.43.3
@@ -84,11 +82,11 @@ require (
 	go.etcd.io/etcd/client/pkg/v3 v3.5.13 // indirect
 	go.uber.org/multierr v1.10.0 // indirect
 	golang.org/x/arch v0.8.0 // indirect
-	golang.org/x/crypto v0.26.0 // indirect
-	golang.org/x/net v0.28.0 // indirect
-	golang.org/x/sync v0.8.0 // indirect
-	golang.org/x/sys v0.23.0 // indirect
-	golang.org/x/text v0.17.0 // indirect
+	golang.org/x/crypto v0.45.0 // indirect
+	golang.org/x/net v0.47.0 // indirect
+	golang.org/x/sync v0.18.0 // indirect
+	golang.org/x/sys v0.38.0 // indirect
+	golang.org/x/text v0.31.0 // indirect
 	google.golang.org/genproto v0.0.0-20230822172742-b8732ec3820d // indirect
 	google.golang.org/genproto/googleapis/api v0.0.0-20230822172742-b8732ec3820d // indirect
 	google.golang.org/genproto/googleapis/rpc v0.0.0-20230822172742-b8732ec3820d // indirect
--- a/go.sum
+++ b/go.sum
@@ -231,8 +231,8 @@ golang.org/x/crypto v0.0.0-20201012173705-84dcc777aaee/go.mod h1:LzIPMQfyMNhhGPh
 golang.org/x/crypto v0.0.0-20201216223049-8b5274cf687f/go.mod h1:jdWPYTVW3xRLrWPugEBEK3UY2ZEsg3UU495nc5E+M+I=
 golang.org/x/crypto v0.0.0-20210921155107-089bfa567519/go.mod h1:GvvjBRRGRdwPK5ydBHafDWAxML/pGHZbMvKqRZ5+Abc=
 golang.org/x/crypto v0.6.0/go.mod h1:OFC/31mSvZgRz0V1QTNCzfAI1aIRzbiufJtkMIlEp58=
-golang.org/x/crypto v0.26.0 h1:RrRspgV4mU+YwB4FYnuBoKsUapNIL5cohGAmSH3azsw=
-golang.org/x/crypto v0.26.0/go.mod h1:GY7jblb9wI+FOo5y8/S2oY4zWP07AkOJ4+jxCqdqn54=
+golang.org/x/crypto v0.45.0 h1:jMBrvKuj23MTlT0bQEOBcAE0mjg8mK9RXFhRH6nyF3Q=
+golang.org/x/crypto v0.45.0/go.mod h1:XTGrrkGJve7CYK7J8PEww4aY7gM3qMCElcJQ8n8JdX4=
 golang.org/x/exp v0.0.0-20190121172915-509febef88a4/go.mod h1:CJ0aWSM057203Lf6IL+f9T1iT9GByDxfZKAQTCR3kQA=
 golang.org/x/lint v0.0.0-20181026193005-c67002cb31c3/go.mod h1:UVdnD1Gm6xHRNCYTkRU2/jEulfH38KcIWyp/GAMgvoE=
 golang.org/x/lint v0.0.0-20190227174305-5b3e6a55c961/go.mod h1:wehouNa3lNwaWXcvxsM5YxQ5yQlVC4a0KAMCusXpPoU=
@@ -254,8 +254,8 @@ golang.org/x/net v0.0.0-20210226172049-e18ecbb05110/go.mod h1:m0MpNAwzfU5UDzcl9v
 golang.org/x/net v0.0.0-20220722155237-a158d28d115b/go.mod h1:XRhObCWvk6IyKnWLug+ECip1KBveYUHfp+8e9klMJ9c=
 golang.org/x/net v0.6.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
 golang.org/x/net v0.7.0/go.mod h1:2Tu9+aMcznHK/AK1HMvgo6xiTLG5rD5rZLDS+rp2Bjs=
-golang.org/x/net v0.28.0 h1:a9JDOJc5GMUJ0+UDqmLT86WiEy7iWyIhz8gz8E4e5hE=
-golang.org/x/net v0.28.0/go.mod h1:yqtgsTWOOnlGLG9GFRrK3++bGOUEkNBoHZc8MEDWPNg=
+golang.org/x/net v0.47.0 h1:Mx+4dIFzqraBXUugkia1OOvlD6LemFo1ALMHjrXDOhY=
+golang.org/x/net v0.47.0/go.mod h1:/jNxtkgq5yWUGYkaZGqo27cfGZ1c5Nen03aYrrKpVRU=
 golang.org/x/oauth2 v0.0.0-20180821212333-d2e6202438be/go.mod h1:N/0e6XlmueqKjAGxoOufVs8QHGRruUQn6yWY3a++T0U=
 golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20181108010431-42b317875d0f/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
@@ -263,8 +263,8 @@ golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJ
 golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
 golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
-golang.org/x/sync v0.8.0 h1:3NFvSEYkUoMifnESzZl15y791HH1qU2xm6eCJU5ZPXQ=
-golang.org/x/sync v0.8.0/go.mod h1:Czt+wKu1gCyEFDUtn0jG5QVvpJ6rzVqr5aXyt9drQfk=
+golang.org/x/sync v0.18.0 h1:kr88TuHDroi+UVf+0hZnirlk8o8T+4MrK6mr60WkH/I=
+golang.org/x/sync v0.18.0/go.mod h1:9KTHXmSnoGruLpwFjVSX0lNNA75CykiMECbovNTZqGI=
 golang.org/x/sys v0.0.0-20180830151530-49385e6e1522/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
 golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
@@ -277,8 +277,8 @@ golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBc
 golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.23.0 h1:YfKFowiIMvtgl1UERQoTPPToxltDeZfbj4H7dVUCwmM=
-golang.org/x/sys v0.23.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
+golang.org/x/sys v0.38.0 h1:3yZWxaJjBmCWXqhN1qh02AkOnCQ1poK6oF+a7xWL6Gc=
+golang.org/x/sys v0.38.0/go.mod h1:OgkHotnGiDImocRcuBABYBEXf8A9a87e/uXjp9XT3ks=
 golang.org/x/term v0.0.0-20201117132131-f5c789dd3221/go.mod h1:Nr5EML6q2oocZ2LXRh80K7BxOlk5/8JxuGnuhpl+muw=
 golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
 golang.org/x/term v0.0.0-20210927222741-03fcf44c2211/go.mod h1:jbD1KX2456YbFQfuXm/mYQcufACuNUgVhRMnK/tPxf8=
@@ -288,8 +288,8 @@ golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.5/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
 golang.org/x/text v0.3.7/go.mod h1:u+2+/6zg+i71rQMx5EYifcz6MCKuco9NR6JIITiCfzQ=
 golang.org/x/text v0.7.0/go.mod h1:mrYo+phRRbMaCq/xk9113O4dZlRixOauAjOtrjsXDZ8=
-golang.org/x/text v0.17.0 h1:XtiM5bkSOt+ewxlOE/aE/AKEHibwj/6gvWMl9Rsh0Qc=
-golang.org/x/text v0.17.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY=
+golang.org/x/text v0.31.0 h1:aC8ghyu4JhP8VojJ2lEHBnochRno1sgL6nEi9WGFGMM=
+golang.org/x/text v0.31.0/go.mod h1:tKRAlv61yKIjGGHX/4tP1LTbc13YSec1pxVEWXzfoeM=
 golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190114222345-bf090417da8b/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
 golang.org/x/tools v0.0.0-20190226205152-f727befe758c/go.mod h1:9Yl7xja0Znq3iFh3HoIrodX9oNMXvdceNzlUR8zjMvY=
--- a/sysmodule/netmodule/wsmodule/WSModule.go
+++ b/sysmodule/netmodule/wsmodule/WSModule.go
@@ -119,6 +119,7 @@ func (ws *WSModule) recyclerReaderBytes([]byte) {
 func (ws *WSModule) NewWSClient(conn *network.WSConn) network.Agent {
 	ws.mapClientLocker.Lock()
 	defer ws.mapClientLocker.Unlock()
+
 	pClient := &WSClient{wsConn: conn, id: primitive.NewObjectID().Hex()}
 	pClient.wsModule = ws
 	ws.mapClient[pClient.id] = pClient
@@ -158,22 +159,6 @@ func (ws *WSModule) GetProcessor() processor.IRawProcessor {
 	return ws.process
 }

-func (ws *WSModule) GetClientHeader(clientId string,key string) string {
-	ws.mapClientLocker.Lock()
-	defer ws.mapClientLocker.Unlock()
-
-	pClient, ok := ws.mapClient[clientId]
-	if ok == false || pClient.wsConn == nil {
-		return ""
-	}
-	
-	if pClient.wsConn.GetHeader() == nil {
-		log.Warn("clientId header is nil", log.String("clientId", clientId))
-	}
-
-	return pClient.wsConn.GetHeader().Get(key)
-}
-
 func (ws *WSModule) GetClientIp(clientId string) string {
 	ws.mapClientLocker.Lock()
 	defer ws.mapClientLocker.Unlock()
--- a/util/blueprint/blueprint.go
+++ b/util/blueprint/blueprint.go
@@ -69,8 +69,6 @@ func (bm *Blueprint) regSysNodes() {
 	bm.RegisterExecNode(NewExecNode[EqualSwitch]())
 	bm.RegisterExecNode(NewExecNode[Probability]())
 	bm.RegisterExecNode(NewExecNode[CreateTimer]())
-	bm.RegisterExecNode(NewExecNode[AppendIntReturn]())
-	bm.RegisterExecNode(NewExecNode[AppendStringReturn]())
 }


--- a/util/blueprint/graph.go
+++ b/util/blueprint/graph.go
@@ -142,17 +142,6 @@ func (gc *graphConfig) GetNodeByID(nodeID string) *nodeConfig {
 	return nil
 }

-func (gr *Graph) GetAndCreateReturnPort() IPort {
-	p, ok := gr.globalVariables[ReturnVarial]
-	if ok && p != nil {
-		return p
-	}
-
-	p = NewPortArray()
-	gr.globalVariables[ReturnVarial] = p
-	return p
-}
-
 func (gr *Graph) Do(entranceID int64, args ...any) (Port_Array, error) {
 	if IsDebug {
 		log.Debug("Graph Do", log.String("graphName", gr.graphFileName), log.Int64("graphID", gr.graphID), log.Int64("entranceID", entranceID))
@@ -168,8 +157,6 @@ func (gr *Graph) Do(entranceID int64, args ...any) (Port_Array, error) {

 	if gr.globalVariables == nil {
 		gr.globalVariables = map[string]IPort{}
-	}else {
-		gr.globalVariables[ReturnVarial] = nil
 	}

 	err := entranceNode.Do(gr, args...)
--- a/util/blueprint/sysnodes.go
+++ b/util/blueprint/sysnodes.go
@@ -681,7 +681,7 @@ func (em *CreateTimer) Exec() (int, error) {

 	array, ok := em.GetInPortArray(1)
 	if !ok {
-		return -1, fmt.Errorf("CreateTimer inParam 1 error")
+		return -1, fmt.Errorf("CreateTimer inParam 0 error")
 	}

 	var timerId uint64
@@ -718,7 +718,7 @@ func (em *CloseTimer) GetName() string {
 func (em *CloseTimer) Exec() (int, error) {
 	timerID, ok := em.GetInPortInt(1)
 	if !ok {
-		return -1, fmt.Errorf("CreateTimer inParam 1 error")
+		return -1, fmt.Errorf("CreateTimer inParam 0 error")
 	}

 	id := uint64(timerID)
@@ -729,56 +729,3 @@ func (em *CloseTimer) Exec() (int, error) {

 	return 0, nil
 }
-
-
-
-
-// AppendIntReturn 追加返回结果(Int)
-type AppendIntReturn struct {
-	BaseExecNode
-}
-
-func (em *AppendIntReturn) GetName() string {
-	return "AppendIntReturn"
-}
-
-func (em *AppendIntReturn) Exec() (int, error) {
-	val, ok := em.GetInPortInt(1)
-	if !ok {
-		return -1, fmt.Errorf("AppendIntReturn inParam 1 error")
-	}
-
-	returnPort := em.gr.GetAndCreateReturnPort()
-	if returnPort == nil {
-		return -1, fmt.Errorf("GetAndCreateReturnPort fail")
-	}
-	returnPort.AppendArrayValInt(val)
-
-	return -0, nil
-}
-
-
-
-// AppendStringReturn 追加返回结果(String)
-type AppendStringReturn struct {
-	BaseExecNode
-}
-
-func (em *AppendStringReturn) GetName() string {
-	return "AppendStringReturn"
-}
-
-func (em *AppendStringReturn) Exec() (int, error) {
-	val, ok := em.GetInPortStr(1)
-	if !ok {
-		return -1, fmt.Errorf("AppendStringReturn inParam 1 error")
-	}
-
-	returnPort := em.gr.GetAndCreateReturnPort()
-	if returnPort == nil {
-		return -1, fmt.Errorf("GetAndCreateReturnPort fail")
-	}
-	returnPort.AppendArrayValStr(val)
-
-	return -0, nil
-}