微服务平台 TSF
有奖捉虫：办公协同&微信生态&物联网文档专题 HOT
文档中心 > 微服务平台 TSF > 开发指南 > Mesh 应用开发 > Demo 工程概述

Demo 工程概述

最近更新时间：2024-01-19 10:55:51

我的收藏

本页目录：

下载 Demo

Demo 语言
下载地址
说明
Python Demo（vm）
-
Python Demo（docker）
-
.NET Demo（vm & docker）
其中 REAME.md 介绍了程序包和镜像两种构建方式
Java Demo（vm）
-
Java Demo (docker)
-
PHP Demo（vm）
其中 README.md 介绍了健康检查的端口和路径
Dubbo Demo（vm）
-
注意
Mesh 的部署和使用与语言无关，具体可参见 Python 使用方式进行改造。

调用说明

下文以 Python Demo 为例进行介绍。Python Demo 提供了3个应用，对应的服务名和应用监听端口为：
user （8089）
shop （8090）
promotion （8091）
3个应用之间的调用关系是：user -> shop -> promotion，相互访问时可以用默认的80或者业务的真实端口（对应 Demo 中的 sidecarPort），如 shop 监听8090，user 访问 shop 可以用shop:80/api/v6/shop/items或者shop:8090/api/v6/shop/items。
注意
Mesh 的调用链通过头传递实现。如果用户想要串联整个服务调用关系，需要在访问其他服务时，带上父调用的9个相关调用链头，具体。
// 9个调用链相关的头，具体说明见(https://www.envoyproxy.io/docs/envoy/v1.8.0/configuration/http_conn_man/headers.html?highlight=tracing)
traceHeaders = ['x-request-id',
                'x-trace-service',
                'x-ot-span-context',
                'x-client-trace-id',
                'x-b3-traceid',
                'x-b3-spanid',
                'x-b3-parentspanid',
                'x-b3-sampled',
                'x-b3-flags']

// 填充调用链相关的头
def build_trace_headers(handler):
    retHeaders = {}
    for header in traceHeaders:
        if handler.headers.has_key(header):
            header_value = handler.headers.get(header)
            retHeaders[header] = header_value
    return retHeaders

// 访问 shop 服务的端口，使用默认的80，或者 shop 的真实端口8090
sidecarPort = 80
def do_GET(self):
    // 调用 shop 服务时填充父调用的调用链相关头
    if self.path == '/api/v6/user/create':
        print "headers are %s" % self.headers.keys()
        logger.info("headers are %s" % self.headers.keys())
        headers = common.build_trace_headers(self)
        if common.sendAndVerify("shop", sidecarPort, "/api/v6/shop/items", headers):
            self.send_response(200)
            self.send_header('Content-type', 'application/json')
            self.end_headers()
            msg = {"result":{"userId":"1234", "userName":"vincent"}}
            self.wfile.write(json.dumps(msg))
        else:
            self.send_response(500)
            self.send_header('Content-type', 'application/json')
            self.end_headers()
            msg = {"exception":"Error invoke %s" % "/api/v6/shop/items"}
            self.wfile.write(json.dumps(msg))

Spring Cloud 应用和 Mesh 应用调用打通 tracing

Spring Cloud 应用和 Mesh 应用相互调用时，如果要打通 tracing，需要在请求中传递调用链相关的 header（参见 上文）。

Demo 工程目录

虚拟机工程目录

以 tsf_python_vm_demo 中的 userService 为例说明虚拟机应用工程目录。
userService.py 和 common.py：Python 应用程序
start.sh：启动脚本
stop.sh：停止脚本
cmdline：检查进程是否存活的文件
spec.yaml：服务描述文件，具体解释请参见 Mesh 开发使用指引。
apis 目录：存放 API 定义的目录， 具体解释请参见 Mesh 开发使用指引。
其中 start.sh、stop.sh、cmdline 的编写方法请参见 程序包格式说明。

容器应用工程目录

以 tsf_python_docker_demo 中的 demo-mesh-user 为例说明容器应用工程目录。
注意
您需要在容器启动后通过用户程序的启动脚本拷贝目录，不可以在 Dockerfile 中提前拷贝。
Dockerfile：使用 userService 目录中 start.sh 脚本来启动 Python 应用。
userService 目录：基本结构类似 tsf_python_vm_demo 中 userService 目录，但是没有 stop.sh 和 cmdline 文件。
start.sh：应用的启动脚本，user demo 的启动脚本如下：
#! /bin/bash
cp /root/app/userService/spec.yaml /opt/tsf/app_config/
cp -r /root/app/userService/apis /opt/tsf/app_config/
cd /root/app/userService/
python ./userService.py 80 1>./logs/user.log 2>&1

脚本说明

应用工作目录为/root/app/userService/，应用日志目录为/root/app/userService/logs/user.log。
第2行：创建/opt/tsf/app_config/apis目录，并将spec.yaml文件拷贝到/opt/tsf/app_config/中。
第3行：将apis目录拷贝到/opt/tsf/app_config/中。
第5行：启动 user 应用。
中国站