|
@@ -1,140 +1,140 @@
|
|
|
-# import nacos
|
|
|
-# import socket
|
|
|
-# import logging
|
|
|
-# import time
|
|
|
-# import os
|
|
|
-# import requests
|
|
|
-# import threading
|
|
|
-#
|
|
|
-# class NacosService:
|
|
|
-# CLIENT = None
|
|
|
-# DATA_ID = None
|
|
|
-# GROUP = None
|
|
|
-# LOCAL_IP = None
|
|
|
-# SERVER_ADDRESSES = None
|
|
|
-# NAMESPACE = None
|
|
|
-# logger = logging.getLogger('app') # 这里设置名字
|
|
|
-#
|
|
|
-# __instance = None
|
|
|
-# _registered = False # 添加注册标志位
|
|
|
-# _stop_event = threading.Event() # 用于控制心跳任务的停止
|
|
|
-#
|
|
|
-# def __init__(self):
|
|
|
-# if os.name == 'posix': # 'posix' 表示类Unix系统,包括Linux
|
|
|
-# default_address = "127.0.0.1:8848"
|
|
|
-# else:
|
|
|
-# default_address = "192.168.3.80:8848"
|
|
|
-# self.LOCAL_IP = str(os.getenv("NACOS_REGISTER_IP", default=socket.gethostbyname(socket.gethostname())))
|
|
|
-# self.SERVER_ADDRESSES = default_address
|
|
|
-# self.NAMESPACE = "dev"
|
|
|
-# self.DATA_ID = "python-mendunr"
|
|
|
-# self.GROUP = "DEFAULT_GROUP"
|
|
|
-#
|
|
|
-# def __new__(cls, *args, **kwargs):
|
|
|
-# if NacosService.__instance is None:
|
|
|
-# NacosService.__instance = object.__new__(cls, *args, **kwargs)
|
|
|
-# return NacosService.__instance
|
|
|
-#
|
|
|
-# ### 获取配置
|
|
|
-# def getConfig(self):
|
|
|
-# return self.CLIENT.get_config(self.DATA_ID, self.GROUP)
|
|
|
-#
|
|
|
-# ### 注册实例
|
|
|
-# def register_instance(self):
|
|
|
-# if self._registered:
|
|
|
-# return
|
|
|
-#
|
|
|
-# res = requests.post(url=f"http://{self.SERVER_ADDRESSES}/nacos/v1/ns/instance",
|
|
|
-# data={
|
|
|
-# 'groupName': self.GROUP,
|
|
|
-# 'metadata': '{"preserved.register.source":"SPRING_CLOUD","preserved.heart.beat.interval": 5500, "preserved.heart.beat.timeout": 30000, "preserved.ip.delete.timeout": 60000}',
|
|
|
-# 'namespaceId': self.NAMESPACE,
|
|
|
-# 'port': 3333,
|
|
|
-# 'enable': True,
|
|
|
-# 'healthy': True,
|
|
|
-# 'clusterName': 'DEFAULT',
|
|
|
-# 'ip': self.LOCAL_IP,
|
|
|
-# 'weight': 1,
|
|
|
-# 'ephemeral': False, # 修改这里为 False
|
|
|
-# 'serviceName': self.GROUP + "@@" + self.DATA_ID
|
|
|
-# })
|
|
|
-# if res.status_code == 200:
|
|
|
-# self.logger.info("register_instance res %s", str(res.content, 'UTF-8'))
|
|
|
-# self._registered = True # 设置注册成功标志位
|
|
|
-# else:
|
|
|
-# self.logger.error(f"Failed to register instance: {res.status_code} - {res.text}")
|
|
|
-#
|
|
|
-# def send_heartbeat(self):
|
|
|
-# while not self._stop_event.is_set():
|
|
|
-# try:
|
|
|
-# res = requests.put(url=f"http://{self.SERVER_ADDRESSES}/nacos/v1/ns/instance/beat",
|
|
|
-# data={
|
|
|
-# "ip": self.LOCAL_IP,
|
|
|
-# "port": "3333",
|
|
|
-# "namespaceId": self.NAMESPACE,
|
|
|
-# "serviceName": self.GROUP + "@@" + self.DATA_ID,
|
|
|
-# "clusterName": "DEFAULT"}
|
|
|
-# )
|
|
|
-# if res.status_code == 200:
|
|
|
-# res_json = res.json()
|
|
|
-# if res_json["code"] == 20404: ### 找不到资源重新注册
|
|
|
-# self.register_instance()
|
|
|
-# else:
|
|
|
-# self.logger.error(f"Failed to send heartbeat: {res.status_code} - {res.text}")
|
|
|
-# self._stop_event.wait(4) ## 4秒执行一次
|
|
|
-# except Exception as e:
|
|
|
-# self.logger.error(f"send_heartbeat error: {e}")
|
|
|
-#
|
|
|
-# def getServer(self, serverName):
|
|
|
-# try:
|
|
|
-# res = requests.get(url=f"http://{self.SERVER_ADDRESSES}/nacos/v1/ns/instance/list",
|
|
|
-# params={'namespaceId': self.NAMESPACE, 'serviceName': self.GROUP + "@@" + serverName})
|
|
|
-# if res.status_code == 200:
|
|
|
-# hosts = res.json()["hosts"]
|
|
|
-# if len(hosts) > 0:
|
|
|
-# return hosts[0]
|
|
|
-# else:
|
|
|
-# self.logger.error(f"Failed to get server list: {res.status_code} - {res.text}")
|
|
|
-# except Exception as e:
|
|
|
-# self.logger.error(f"getServer error: {e}")
|
|
|
-# return None
|
|
|
-#
|
|
|
-# def start(self):
|
|
|
-# try:
|
|
|
-# self.CLIENT = nacos.NacosClient(self.SERVER_ADDRESSES, namespace=self.NAMESPACE)
|
|
|
-# self.register_instance()
|
|
|
-# self.heartbeat_thread = threading.Thread(target=self.send_heartbeat)
|
|
|
-# self.heartbeat_thread.start()
|
|
|
-# except Exception as e:
|
|
|
-# self.logger.error(f"start error: {e}")
|
|
|
-#
|
|
|
-# def stop(self):
|
|
|
-# self._stop_event.set()
|
|
|
-# self.heartbeat_thread.join()
|
|
|
-#
|
|
|
-# def get_nacos_configs(self):
|
|
|
-# url = f"http://{self.SERVER_ADDRESSES}/nacos/v1/cs/configs"
|
|
|
-# params = {
|
|
|
-# 'tenant': self.NAMESPACE,
|
|
|
-# 'dataId': self.DATA_ID,
|
|
|
-# 'group': self.GROUP
|
|
|
-# }
|
|
|
-# try:
|
|
|
-# r = requests.get(url, params)
|
|
|
-# r.encoding = r.apparent_encoding
|
|
|
-# if r.status_code == 200:
|
|
|
-# r_dict = r.json()
|
|
|
-# return r_dict
|
|
|
-# else:
|
|
|
-# self.logger.error(f"Failed to get Nacos configs: {r.status_code} - {r.text}")
|
|
|
-# except Exception as e:
|
|
|
-# self.logger.error(f"get_nacos_configs error: {e}")
|
|
|
-# return None
|
|
|
-#
|
|
|
-#
|
|
|
-# nacos_service_single = NacosService()
|
|
|
-#
|
|
|
-#
|
|
|
-# # 发送url请求,获取nacos上的配置
|
|
|
-# def get_nacos_configs():
|
|
|
-# return nacos_service_single.get_nacos_configs()
|
|
|
+import nacos
|
|
|
+import socket
|
|
|
+import logging
|
|
|
+import time
|
|
|
+import os
|
|
|
+import requests
|
|
|
+import threading
|
|
|
+
|
|
|
+class NacosService:
|
|
|
+ CLIENT = None
|
|
|
+ DATA_ID = None
|
|
|
+ GROUP = None
|
|
|
+ LOCAL_IP = None
|
|
|
+ SERVER_ADDRESSES = None
|
|
|
+ NAMESPACE = None
|
|
|
+ logger = logging.getLogger('app') # 这里设置名字
|
|
|
+
|
|
|
+ __instance = None
|
|
|
+ _registered = False # 添加注册标志位
|
|
|
+ _stop_event = threading.Event() # 用于控制心跳任务的停止
|
|
|
+
|
|
|
+ def __init__(self):
|
|
|
+ if os.name == 'posix': # 'posix' 表示类Unix系统,包括Linux
|
|
|
+ default_address = "127.0.0.1:8848"
|
|
|
+ else:
|
|
|
+ default_address = "192.168.3.80:8848"
|
|
|
+ self.LOCAL_IP = str(os.getenv("NACOS_REGISTER_IP", default=socket.gethostbyname(socket.gethostname())))
|
|
|
+ self.SERVER_ADDRESSES = default_address
|
|
|
+ self.NAMESPACE = "dev"
|
|
|
+ self.DATA_ID = "python-mendunr"
|
|
|
+ self.GROUP = "DEFAULT_GROUP"
|
|
|
+
|
|
|
+ def __new__(cls, *args, **kwargs):
|
|
|
+ if NacosService.__instance is None:
|
|
|
+ NacosService.__instance = object.__new__(cls, *args, **kwargs)
|
|
|
+ return NacosService.__instance
|
|
|
+
|
|
|
+ ### 获取配置
|
|
|
+ def getConfig(self):
|
|
|
+ return self.CLIENT.get_config(self.DATA_ID, self.GROUP)
|
|
|
+
|
|
|
+ ### 注册实例
|
|
|
+ def register_instance(self):
|
|
|
+ if self._registered:
|
|
|
+ return
|
|
|
+
|
|
|
+ res = requests.post(url=f"http://{self.SERVER_ADDRESSES}/nacos/v1/ns/instance",
|
|
|
+ data={
|
|
|
+ 'groupName': self.GROUP,
|
|
|
+ 'metadata': '{"preserved.register.source":"SPRING_CLOUD","preserved.heart.beat.interval": 5500, "preserved.heart.beat.timeout": 30000, "preserved.ip.delete.timeout": 60000}',
|
|
|
+ 'namespaceId': self.NAMESPACE,
|
|
|
+ 'port': 3333,
|
|
|
+ 'enable': True,
|
|
|
+ 'healthy': True,
|
|
|
+ 'clusterName': 'DEFAULT',
|
|
|
+ 'ip': self.LOCAL_IP,
|
|
|
+ 'weight': 1,
|
|
|
+ 'ephemeral': False, # 修改这里为 False
|
|
|
+ 'serviceName': self.GROUP + "@@" + self.DATA_ID
|
|
|
+ })
|
|
|
+ if res.status_code == 200:
|
|
|
+ self.logger.info("register_instance res %s", str(res.content, 'UTF-8'))
|
|
|
+ self._registered = True # 设置注册成功标志位
|
|
|
+ else:
|
|
|
+ self.logger.error(f"Failed to register instance: {res.status_code} - {res.text}")
|
|
|
+
|
|
|
+ def send_heartbeat(self):
|
|
|
+ while not self._stop_event.is_set():
|
|
|
+ try:
|
|
|
+ res = requests.put(url=f"http://{self.SERVER_ADDRESSES}/nacos/v1/ns/instance/beat",
|
|
|
+ data={
|
|
|
+ "ip": self.LOCAL_IP,
|
|
|
+ "port": "3333",
|
|
|
+ "namespaceId": self.NAMESPACE,
|
|
|
+ "serviceName": self.GROUP + "@@" + self.DATA_ID,
|
|
|
+ "clusterName": "DEFAULT"}
|
|
|
+ )
|
|
|
+ if res.status_code == 200:
|
|
|
+ res_json = res.json()
|
|
|
+ if res_json["code"] == 20404: ### 找不到资源重新注册
|
|
|
+ self.register_instance()
|
|
|
+ else:
|
|
|
+ self.logger.error(f"Failed to send heartbeat: {res.status_code} - {res.text}")
|
|
|
+ self._stop_event.wait(4) ## 4秒执行一次
|
|
|
+ except Exception as e:
|
|
|
+ self.logger.error(f"send_heartbeat error: {e}")
|
|
|
+
|
|
|
+ def getServer(self, serverName):
|
|
|
+ try:
|
|
|
+ res = requests.get(url=f"http://{self.SERVER_ADDRESSES}/nacos/v1/ns/instance/list",
|
|
|
+ params={'namespaceId': self.NAMESPACE, 'serviceName': self.GROUP + "@@" + serverName})
|
|
|
+ if res.status_code == 200:
|
|
|
+ hosts = res.json()["hosts"]
|
|
|
+ if len(hosts) > 0:
|
|
|
+ return hosts[0]
|
|
|
+ else:
|
|
|
+ self.logger.error(f"Failed to get server list: {res.status_code} - {res.text}")
|
|
|
+ except Exception as e:
|
|
|
+ self.logger.error(f"getServer error: {e}")
|
|
|
+ return None
|
|
|
+
|
|
|
+ def start(self):
|
|
|
+ try:
|
|
|
+ self.CLIENT = nacos.NacosClient(self.SERVER_ADDRESSES, namespace=self.NAMESPACE)
|
|
|
+ self.register_instance()
|
|
|
+ self.heartbeat_thread = threading.Thread(target=self.send_heartbeat)
|
|
|
+ self.heartbeat_thread.start()
|
|
|
+ except Exception as e:
|
|
|
+ self.logger.error(f"start error: {e}")
|
|
|
+
|
|
|
+ def stop(self):
|
|
|
+ self._stop_event.set()
|
|
|
+ self.heartbeat_thread.join()
|
|
|
+
|
|
|
+ def get_nacos_configs(self):
|
|
|
+ url = f"http://{self.SERVER_ADDRESSES}/nacos/v1/cs/configs"
|
|
|
+ params = {
|
|
|
+ 'tenant': self.NAMESPACE,
|
|
|
+ 'dataId': self.DATA_ID,
|
|
|
+ 'group': self.GROUP
|
|
|
+ }
|
|
|
+ try:
|
|
|
+ r = requests.get(url, params)
|
|
|
+ r.encoding = r.apparent_encoding
|
|
|
+ if r.status_code == 200:
|
|
|
+ r_dict = r.json()
|
|
|
+ return r_dict
|
|
|
+ else:
|
|
|
+ self.logger.error(f"Failed to get Nacos configs: {r.status_code} - {r.text}")
|
|
|
+ except Exception as e:
|
|
|
+ self.logger.error(f"get_nacos_configs error: {e}")
|
|
|
+ return None
|
|
|
+
|
|
|
+
|
|
|
+nacos_service_single = NacosService()
|
|
|
+
|
|
|
+
|
|
|
+# 发送url请求,获取nacos上的配置
|
|
|
+def get_nacos_configs():
|
|
|
+ return nacos_service_single.get_nacos_configs()
|