使用背景
作为一个java开发，大部分应该都使用过 dubbo 和 springcloud 框架；java的服务模块可以做到方便的注册和发现，现今有基于python的功能模块想要直接像java服务一样发现和管理~
之前考虑过注册到dubbo,可惜还没成功；
注册到springcloude 目前测试是可以的，可以在和java模块一起管理，公用java的权限拦截器，geteway路由等功能，还是比较方便的。
本地环境
python3.7
依赖包
pip install py_eureka_client
api地址
https://pypi.org/project/py-eureka-client/
eureka服务 是java的spring-cloud启动的
java依赖包,启动的eureka服务中心
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>Finchley.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
python 服务注册
服务注册样例
'''https://pypi.org/project/py-eureka-client/ 服务注册样例'''
# coding:utf-8
import tornado.httpserver
import tornado.ioloop
import tornado.options
from tornado.web import RequestHandler
import py_eureka_client.eureka_client as eureka_client
from tornado.options import define, options
define("port", default=8011, help="run on the given port", type=int)
# restfulAPI功能实现在这里
class Info_handler(RequestHandler):
def get(self):
self.write("my is info url ")
# restfulAPI功能实现在这里
class Test_handler(RequestHandler):
def get(self):
self.write("my is test url ")
# 注册服务
def eurekaclient():
tornado.options.parse_command_line()
# 注册eureka服务
eureka_client.init_registry_client(eureka_server="http://localhost:5000/eureka/",
app_name="python-service",
instance_port=8011)
# 提供外部调用的接口
app = tornado.web.Application(handlers=[(r"/info", Info_handler),
(r"/python/test", Test_handler)])
http_server = tornado.httpserver.HTTPServer(app)
http_server.listen(options.port)
tornado.ioloop.IOLoop.instance().start()
print("eureka exec")
if __name__ == "__main__":
eurekaclient()
服务调用样例：
import py_eureka_client.eureka_client as eureka_client
# 注册并发现服务
eureka_client.init(eureka_server="http://localhost:5000/eureka/", app_name="do_service", instance_port=9090)
res = eureka_client.do_service("python-service", "/python/test")
print("result of other service" + res)
客户端初始化注册类型
注册并发现服务
这是使用此组件的最简单方法。注册自己，并可以获取eureka中心的服务列表信息（即可以通过服务名调用其他服务接口）
eureka_client.init(eureka_server="http://localhost:5000/eureka/", app_name="do_service", instance_port=9090)
仅使用注册表客户端
如果您的服务器仅提供服务，而无需其他组件的服务，则只能将客户端注册到Eureka服务器，而忽略发现客户端。
eureka_client.init_registry_client(eureka_server="http://localhost:5000/eureka/", app_name="do_service", instance_port=9090)
使用发现服务
如果您的服务不提供服务，但想使用其他组件的服务，则只能使用此发现客户端。
首先，在服务器启动后初始化发现客户端。
eureka_client.init_discovery_client("http://localhost:5000/eureka/",ha_strategy=eureka_client.HA_STRATEGY_STICK)
高可用策略
使用发现客户端时，有几种高可用性策略。 他们是：
- HA_STRATEGY_RANDOM，默认策略，随机找到一个节点。
- HA_STRATEGY_STICK，使用一个节点，直到它崩溃为止。
- HA_STRATEGY_OTHER，请始终使用与上次不同的节点。
# General init method
eureka_client.init(eureka_server="http://your-eureka-server-peer1,http://your-eureka-server-peer2",
app_name="your_app_name",
instance_port=9090,
ha_strategy=eureka_client.HA_STRATEGY_STICK)
# If you only use the discovery client
eureka_client.init_discovery_client("http://192.168.3.116:8761/eureka/, http://192.168.3.116:8762/eureka/",
ha_strategy=eureka_client.HA_STRATEGY_STICK)
调用方式
需要客户端注册 方式是可以发现服务列表的
常用的同步调用
eureka_client.init(eureka_server="http://localhost:5000/eureka/", app_name="do_service", instance_port=9090)
res = eureka_client.do_service("python-service", "/python/test")
print("result of other service" + res)
异步调用
def success_callabck(data):
# type: (Union[str, dict]) -> object
# do what you will use of the result.
print("success_callabck")
print(data)
def error_callback(error):
# type: (urllib.request.HTTPError) -> object
# do what you need to do when error occures
print("error")
print(error)
# 异步调用
eureka_client.do_service_async("python-service", "/test", on_success=success_callabck,on_error=error_callback)
