当前位置:   article > 正文

SpringCloud 整合Python_jython 怎么整合springboot

jython 怎么整合springboot

参考文章:

SpringCloud 整合Python

spring-cloud-sidecar集成非java服务端(php,node.js,paython)到spring cloud

SpringCloud Sidecar使用

Spring Cloud微服务解决方案⑨:Sidecar异构

Spring Cloud之Zuul(七):主要实现非jvm语言结合Sidecar实现服务注册

目录

Sidecar简介

一.搭建python服务

1.新建py_test.py

二.搭建spring-sidecar-python-server工程

1.pom.xml文件

2.application.yml文件配置

3.springboot main入口文件

三.搭建spring-sidecar-python-caller工程

1.pom.xml文件

2.application.yml文件配置

3.springboot main入口文件

4.controller文件

Sidecar简介

  • 在springcloud的项目中,我们需要允许使用不同语言去实现微服务,但是非java语言是无法接入eureka,hystrix,fegin,ribbon等相关组件。有一种思路就是启动一个代理的微服务,由该代理微服务同非jvm服务交流,并接入eureka等相关组件。Sidecar就是该思路的实现,总结的说就是作为一个代理的服务来间接性的让其他语言可以使用Eureka等相关组件。
  • 目前sidecar这个服务必须和非jvm语言的服务在同一台主机上面,也就是说他们之间是localhost访问的,不能是ip访问等等
  • 目前觉得sidecar还不是非常适用,如每一个异构的微服务都要对应的建一个sidecar的微服务,十分不合理。
  • 通过sidecar微服务异构其它类型服务后,该微服务异构的服务, 只能通过其它微服务调用该微服务才能访问,且调用方式只能使用ribbon调用, feign和zuul调用均失败

前提: 这里假设eureka注册中心已搭建完成

一.搭建python服务

1.新建py_test.py

python可访问服务地址如下::http://localhost:3000/health, http://localhost:3000/getUser

内容如下:

  1. import json
  2. from flask import Flask, Response
  3. app = Flask(__name__)
  4. @app.route("/health")
  5. def health():
  6. result = {'status': 'UP'} # UP要大写
  7. # response header里面解析的text/html, 应该改成application/json
  8. return Response(json.dumps(result), mimetype='application/json')
  9. @app.route("/getUser")
  10. def getUser():
  11. result = {'username': 'python', 'password': 'python'}
  12. return Response(json.dumps(result), mimetype='application/json')
  13. app.run(port=3000, host='0.0.0.0')

二.搭建spring-sidecar-python-server工程

该工程负责调用步骤一中的python工程

1.pom.xml文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  5. <!--<parent>-->
  6. <!--<groupId>com.cloud</groupId>-->
  7. <!--<artifactId>cloud-parent</artifactId>-->
  8. <!--<version>0.0.1-SNAPSHOT</version>-->
  9. <!--</parent>-->
  10. <!--<properties>-->
  11. <!--<project-name>spring-sidecar-python-server</project-name>-->
  12. <!--</properties>-->
  13. <!-- 定义公共资源版本 -->
  14. <parent>
  15. <groupId>org.springframework.boot</groupId>
  16. <artifactId>spring-boot-starter-parent</artifactId>
  17. <version>2.0.5.RELEASE</version>
  18. <relativePath/>
  19. </parent>
  20. <properties>
  21. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  22. <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  23. <java.version>1.8</java.version>
  24. <spring-cloud.version>Finchley.SR2</spring-cloud.version>
  25. <project-name>spring-sidecar-python-server</project-name>
  26. </properties>
  27. <artifactId>${project-name}</artifactId>
  28. <version>0.0.1-SNAPSHOT</version>
  29. <packaging>jar</packaging>
  30. <name>${project-name}</name>
  31. <description>${project-name}</description>
  32. <dependencies>
  33. <!-- 包含 mvc,aop 等jar资源 -->
  34. <dependency>
  35. <groupId>org.springframework.boot</groupId>
  36. <artifactId>spring-boot-starter-web</artifactId>
  37. </dependency>
  38. <!--其依赖ribbon, hystrix等-->
  39. <dependency>
  40. <groupId>org.springframework.cloud</groupId>
  41. <artifactId>spring-cloud-netflix-sidecar</artifactId>
  42. </dependency>
  43. <dependency>
  44. <groupId>org.springframework.cloud</groupId>
  45. <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
  46. </dependency>
  47. <!--<dependency>-->
  48. <!--<groupId>org.springframework.cloud</groupId>-->
  49. <!--<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>-->
  50. <!--</dependency>-->
  51. </dependencies>
  52. <!--依赖管理, 用于管理spring-cloud的依赖, 其中Camden.SR3是版本号-->
  53. <dependencyManagement>
  54. <dependencies>
  55. <dependency>
  56. <groupId>org.springframework.cloud</groupId>
  57. <artifactId>spring-cloud-dependencies</artifactId>
  58. <version>${spring-cloud.version}</version>
  59. <type>pom</type>
  60. <scope>import</scope>
  61. </dependency>
  62. </dependencies>
  63. </dependencyManagement>
  64. <!--远程仓库-->
  65. <repositories>
  66. <repository>
  67. <id>spring-snapshots</id>
  68. <name>Spring Snapshots</name>
  69. <url>https://repo.spring.io/snapshot</url>
  70. <snapshots>
  71. <enabled>true</enabled>
  72. </snapshots>
  73. </repository>
  74. <repository>
  75. <id>spring-milestones</id>
  76. <name>Spring Milestones</name>
  77. <url>https://repo.spring.io/milestone</url>
  78. <snapshots>
  79. <enabled>false</enabled>
  80. </snapshots>
  81. </repository>
  82. </repositories>
  83. </project>

2.application.yml文件配置

  1. #用于开发环境
  2. spring:
  3. application:
  4. name: spring-sidecar-python-server #ServiceId, 配置服务命名,不区分大小写,在注册中心管理界面默认大写显示
  5. server:
  6. port: 10230
  7. eureka.client.service-url.defaultZone: http://10.101.15.59:18000/eureka/
  8. sidecar:
  9. port: 3000
  10. health-uri: http://localhost:${sidecar.port}/health # 这里必须是localhost
  11. # ========================= eureka client =========================== #
  12. eureka:
  13. client:
  14. service-url:
  15. # defaultZone: http://peer1:8000/eureka/,http://peer2:8001/eureka/,http://peer3:8002/eureka/
  16. defaultZone: http://10.101.15.59:18000/eureka/
  17. instance:
  18. #不使用主机名来定义注册中心的地址, 而使用IP地址的形式,
  19. #如果设置了 ipAddress 属性, 则使用该属性配置的IP, 否则自动获取除环路IP外的第一个IP地址
  20. preferIpAddress: true #自动将IP注册到Eureka Server上, 如果不配置就是机器的主机名
  21. #ipAddress: 192.168.1.128 # IP地址
  22. #将Instance ID设置成IP:端口的形式
  23. instance-id: ${spring.cloud.client.ip-address}:${spring.application.name}:${server.port}

3.springboot main入口文件

  1. package com.cloud;
  2. import org.springframework.boot.SpringApplication;
  3. import org.springframework.boot.autoconfigure.SpringBootApplication;
  4. import org.springframework.cloud.netflix.sidecar.EnableSidecar;
  5. // @EnableSidecar是一个组合注解, 它整合了三个注解,
  6. // 分别是:@EnableCircuitBreaker、@EnableDiscoveryClient、@EnableZuulProxy
  7. @EnableSidecar
  8. @SpringBootApplication
  9. public class SidecarPythonServerApplication {
  10. public static void main(String[] args) {
  11. SpringApplication.run(SidecarPythonServerApplication.class, args);
  12. }
  13. }

三.搭建spring-sidecar-python-caller工程

该工程负责调用步骤二中的spring-sidecar-python-server工程

1.pom.xml文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3. xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  4. <modelVersion>4.0.0</modelVersion>
  5. <!--<parent>-->
  6. <!--<groupId>com.cloud</groupId>-->
  7. <!--<artifactId>cloud-parent</artifactId>-->
  8. <!--<version>0.0.1-SNAPSHOT</version>-->
  9. <!--</parent>-->
  10. <!--<properties>-->
  11. <!--<project-name>spring-sidecar-python-server</project-name>-->
  12. <!--</properties>-->
  13. <!-- 定义公共资源版本 -->
  14. <parent>
  15. <groupId>org.springframework.boot</groupId>
  16. <artifactId>spring-boot-starter-parent</artifactId>
  17. <version>2.0.5.RELEASE</version>
  18. <relativePath/>
  19. </parent>
  20. <properties>
  21. <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  22. <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  23. <java.version>1.8</java.version>
  24. <spring-cloud.version>Finchley.SR2</spring-cloud.version>
  25. <project-name>spring-sidecar-python-caller</project-name>
  26. </properties>
  27. <artifactId>${project-name}</artifactId>
  28. <version>0.0.1-SNAPSHOT</version>
  29. <packaging>jar</packaging>
  30. <name>${project-name}</name>
  31. <description>${project-name}</description>
  32. <dependencies>
  33. <!--Hystrix 依赖 主要是用 @HystrixCommand-->
  34. <dependency>
  35. <groupId>org.springframework.cloud</groupId>
  36. <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
  37. </dependency>
  38. </dependencies>
  39. <!--依赖管理, 用于管理spring-cloud的依赖, 其中Camden.SR3是版本号-->
  40. <dependencyManagement>
  41. <dependencies>
  42. <dependency>
  43. <groupId>org.springframework.cloud</groupId>
  44. <artifactId>spring-cloud-dependencies</artifactId>
  45. <version>${spring-cloud.version}</version>
  46. <type>pom</type>
  47. <scope>import</scope>
  48. </dependency>
  49. </dependencies>
  50. </dependencyManagement>
  51. <!--远程仓库-->
  52. <repositories>
  53. <repository>
  54. <id>spring-snapshots</id>
  55. <name>Spring Snapshots</name>
  56. <url>https://repo.spring.io/snapshot</url>
  57. <snapshots>
  58. <enabled>true</enabled>
  59. </snapshots>
  60. </repository>
  61. <repository>
  62. <id>spring-milestones</id>
  63. <name>Spring Milestones</name>
  64. <url>https://repo.spring.io/milestone</url>
  65. <snapshots>
  66. <enabled>false</enabled>
  67. </snapshots>
  68. </repository>
  69. </repositories>
  70. </project>

2.application.yml文件配置

  1. spring:
  2. application:
  3. name: spring-sidecar-python-caller #ServiceId, 配置服务命名,不区分大小写,在注册中心管理界面默认大写显示
  4. server:
  5. port: 10232
  6. eureka.client.service-url.defaultZone: http://10.101.15.159:18000/eureka/

3.springboot main入口文件

  1. package com.cloud;
  2. import org.springframework.boot.SpringApplication;
  3. import org.springframework.boot.autoconfigure.SpringBootApplication;
  4. import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
  5. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  6. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.web.client.RestTemplate;
  9. @EnableEurekaClient
  10. @EnableCircuitBreaker
  11. @SpringBootApplication
  12. public class SidecarPythonCallerApplication {
  13. public static void main(String[] args) {
  14. SpringApplication.run(SidecarPythonCallerApplication.class, args);
  15. }
  16. /**
  17. * 让restTemplate具备Ribbon负载均衡的能力。
  18. * 由于使用feign, 弃用该方式
  19. */
  20. @Bean
  21. @LoadBalanced
  22. RestTemplate restTemplate() {
  23. return new RestTemplate();
  24. }
  25. }

4.controller文件

  1. package com.cloud.controller;
  2. import com.cloud.service.SidecarPythonCallerService;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.web.bind.annotation.RequestMapping;
  5. import org.springframework.web.bind.annotation.RestController;
  6. import org.springframework.web.client.RestTemplate;
  7. /**
  8. * @author Administrator 2018/10/29
  9. */
  10. @RestController
  11. @RequestMapping(value = "/")
  12. public class SidecarPythonCallerController {
  13. @RequestMapping("/java-user")
  14. public String JavaUser() {
  15. return "{'username': 'java', 'password': 'java'}" ;
  16. }
  17. @RequestMapping("/python-user")
  18. public String PythonUser() {
  19. return restTemplate.getForEntity("http://spring-sidecar-python-server/getUser", String.class).getBody();
  20. }
  21. }

全部启动完成后, 

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小惠珠哦/article/detail/1016926
推荐阅读
相关标签
  

闽ICP备14008679号