SpingCloud之feign框架调用

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <groupId>com.example</groupId>    <artifactId>cloud-provider</artifactId>    <version>0.0.1-SNAPSHOT</version>    <packaging>jar</packaging>    <name>cloud-provider</name>    <description>Demo project for Spring Boot</description>    <parent>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-parent</artifactId>        <version>2.0.6.RELEASE</version>        <relativePath/> <!-- lookup parent from repository -->    </parent>    <properties>        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>        <java.version>1.8</java.version>        <spring-cloud.version>Finchley.SR2</spring-cloud.version>    </properties>    <dependencies>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>        <dependency>            <groupId>org.mybatis.spring.boot</groupId>            <artifactId>mybatis-spring-boot-starter</artifactId>            <version>1.3.2</version>        </dependency>        <!--Service Discovery with Zookeeper-->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-devtools</artifactId>            <scope>runtime</scope>        </dependency>        <dependency>            <groupId>mysql</groupId>            <artifactId>mysql-connector-java</artifactId>        </dependency>        <dependency>            <groupId>org.projectlombok</groupId>            <artifactId>lombok</artifactId>            <optional>true</optional>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-test</artifactId>            <scope>test</scope>        </dependency>    </dependencies>    <dependencyManagement>        <dependencies>            <dependency>                <groupId>org.springframework.cloud</groupId>                <artifactId>spring-cloud-dependencies</artifactId>                <version>${spring-cloud.version}</version>                <type>pom</type>                <scope>import</scope>            </dependency>        </dependencies>    </dependencyManagement>    <build>        <plugins>            <plugin>                <groupId>org.springframework.boot</groupId>                <artifactId>spring-boot-maven-plugin</artifactId>                <configuration>                    <fork>true</fork>                </configuration>            </plugin>        </plugins>    </build></project>

spring:  datasource:    driver-class-name: com.mysql.jdbc.Driver    url:  jdbc:mysql:///testdb?useSSL=true    username: root    password: 123  cloud:    zookeeper:      connect-string: 192.168.3.201:2181  application:    name: providermybatis:  configuration:    map-underscore-to-camel-case: true  mapper-locations: classpath:mapper/*Mapper.xmllogging:  level:    com.example.cloudprovider.mapper: debug

package com.example.cloudprovider.domain;import lombok.Getter;import lombok.Setter;import java.util.Date;@Setter@Getterpublic class UserInfo {    private Integer userId;    private String userName;    private int userAge;    private Date userBirth;}

package com.example.cloudprovider.mapper;import com.example.cloudprovider.domain.UserInfo;public interface UserInfoMapper {    UserInfo getUser(Integer userId);}

<?xml version="1.0" encoding="UTF-8" ?><!DOCTYPE mapper        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"        "http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mapper namespace="com.example.cloudprovider.mapper.UserInfoMapper">    <select id="getUser" resultType="com.example.cloudprovider.domain.UserInfo">        select user_id, user_name, user_age, user_birth from t_user where user_id = #{userId}    </select></mapper>

package com.example.cloudprovider.service;import com.example.cloudprovider.domain.UserInfo;public interface UserService {    UserInfo getUser(Integer userId);}

package com.example.cloudprovider.service.impl;import com.example.cloudprovider.domain.UserInfo;import com.example.cloudprovider.mapper.UserInfoMapper;import com.example.cloudprovider.service.UserService;import org.springframework.stereotype.Service;import javax.annotation.Resource;@Servicepublic class UserServiceImpl implements UserService {    @Resource    private UserInfoMapper userMapper;    @Override    public UserInfo getUser(Integer userId) {        return userMapper.getUser(userId);    }}

package com.example.cloudprovider.controller;import com.example.cloudprovider.domain.UserInfo;import com.example.cloudprovider.service.UserService;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;@RestControllerpublic class UserInfoController {    @Autowired    private UserService userService;    @GetMapping("user/{id}")    public UserInfo getUser(@PathVariable("id") Integer userId) {        return userService.getUser(userId);    }}

package com.example.cloudprovider;import org.mybatis.spring.annotation.MapperScan;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication@MapperScan("com.example.cloudprovider.mapper") //扫描Mapper类 注入到Spring容器中public class CloudProviderApplication {    public static void main(String[] args) {        SpringApplication.run(CloudProviderApplication.class, args);    }}

<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">    <modelVersion>4.0.0</modelVersion>    <groupId>com.example</groupId>    <artifactId>cloud-consumer</artifactId>    <version>0.0.1-SNAPSHOT</version>    <packaging>jar</packaging>    <name>cloud-consumer</name>    <description>Demo project for Spring Boot</description>    <parent>        <groupId>org.springframework.boot</groupId>        <artifactId>spring-boot-starter-parent</artifactId>        <version>2.0.6.RELEASE</version>        <relativePath/> <!-- lookup parent from repository -->    </parent>    <properties>        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>        <java.version>1.8</java.version>        <spring-cloud.version>Finchley.SR2</spring-cloud.version>    </properties>    <dependencyManagement>        <dependencies>            <dependency>                <groupId>org.springframework.cloud</groupId>                <artifactId>spring-cloud-dependencies</artifactId>                <version>${spring-cloud.version}</version>                <type>pom</type>                <scope>import</scope>            </dependency>        </dependencies>    </dependencyManagement>    <dependencies>        <!-- 引入feign依赖 -->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-openfeign</artifactId>        </dependency>        <!--Service Discovery with Zookeeper-->        <dependency>            <groupId>org.springframework.cloud</groupId>            <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-web</artifactId>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-devtools</artifactId>            <scope>runtime</scope>        </dependency>        <dependency>            <groupId>org.projectlombok</groupId>            <artifactId>lombok</artifactId>            <optional>true</optional>        </dependency>        <dependency>            <groupId>org.springframework.boot</groupId>            <artifactId>spring-boot-starter-test</artifactId>            <scope>test</scope>        </dependency>    </dependencies>    <build>        <plugins>            <plugin>                <groupId>org.springframework.boot</groupId>                <artifactId>spring-boot-maven-plugin</artifactId>                <configuration>                    <fork>true</fork>                </configuration>            </plugin>        </plugins>    </build></project>

spring:  cloud:    zookeeper:      connect-string: 192.168.3.201:2181      discovery:        register: false #不会注册到zk中provider: # 服务名称    ribbon: # 负载均衡实现依靠ribbon    　　# 负载策略      NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RandomRule #随机策略  其他策略百度

package com.example.cloudconsumer.vo;import lombok.Getter;import lombok.Setter;import java.util.Date;@Getter@Setterpublic class UserVO {    private Integer userId;    private String userName;    private Date userBirth;}

package com.example.cloudconsumer.config;import org.springframework.boot.SpringBootConfiguration;import org.springframework.cloud.client.loadbalancer.LoadBalanced;import org.springframework.context.annotation.Bean;import org.springframework.web.client.RestTemplate;@SpringBootConfigurationpublic class RestTemplateConfiguration {    @Bean    @LoadBalanced // Ribbon 负载均衡    public RestTemplate restTemplate() {        return new RestTemplate();    }}

package com.example.cloudconsumer.controller;import com.example.cloudconsumer.vo.UserVO;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;import org.springframework.web.client.RestTemplate;@RestControllerpublic class UserWarpController {    @Autowired    private RestTemplate restTemplate;    // 调用只有一个或者多个服务实例API的情况下    @GetMapping("warp/user/{userId}")    public UserVO getUserData(@PathVariable("userId") Integer userId) {        return restTemplate.getForObject("http://provider/user/"+userId, UserVO.class);    }}

package com.example.cloudconsumer.controller;import com.example.cloudconsumer.client.UserClient;import com.example.cloudconsumer.vo.UserVO;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RestController;import javax.annotation.Resource;@RestControllerpublic class UserFeignController {    @Resource    private UserClient userClient;    // 调用只有一个或者多个服务实例API的情况下    @GetMapping("feign/user/{userId}")    public UserVO getUserData(@PathVariable("userId") Integer userId) {        return userClient.getUserData(userId);    }}

package com.example.cloudconsumer.client;import com.example.cloudconsumer.vo.UserVO;import org.springframework.cloud.openfeign.FeignClient;import org.springframework.web.bind.annotation.GetMapping;import org.springframework.web.bind.annotation.PathVariable;/** * @FeignClient(name = "provider") * name为调用服务端的spring.application.name的值 */@FeignClient(name = "provider")public interface UserClient {    @GetMapping("user/{id}")    public UserVO getUserData(@PathVariable("id") Integer userId);}

package com.example.cloudconsumer;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;import org.springframework.cloud.client.discovery.EnableDiscoveryClient;import org.springframework.cloud.openfeign.EnableFeignClients;@SpringBootApplication@EnableDiscoveryClient //可以发现ZK的服务@EnableFeignClients //可以发现feign的服务public class CloudConsumerApplication {    public static void main(String[] args) {        SpringApplication.run(CloudConsumerApplication.class, args);    }}