SpingCloud之feign框架調用

阿新 • • 發佈：2018-10-27

for type namespace tco war bind 消費 mode 生產者

1.生產者（沒有什麽特殊性）

技術分享圖片

pom.xml

<?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>

application.yml

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: provider
mybatis:
  configuration:
    map-underscore-to-camel-case: true
  mapper-locations: classpath:mapper/*Mapper.xml

logging:
  level:
    com.example.cloudprovider.mapper: debug

實體類

package com.example.cloudprovider.domain;

import lombok.Getter;
import lombok.Setter;

import java.util.Date;

@Setter
@Getter
public class UserInfo {
    private Integer userId;
    private String userName;
    private int userAge;
    private Date userBirth;
}

Mapper

package com.example.cloudprovider.mapper;

import com.example.cloudprovider.domain.UserInfo;

public interface UserInfoMapper {
    UserInfo getUser(Integer userId);
}

Mapper.xml

<?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>

Service接口

package com.example.cloudprovider.service;

import com.example.cloudprovider.domain.UserInfo;

public interface UserService {
    UserInfo getUser(Integer userId);
}

Service實現

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;

@Service
public class UserServiceImpl implements UserService {

    @Resource
    private UserInfoMapper userMapper;

    @Override
    public UserInfo getUser(Integer userId) {
        return userMapper.getUser(userId);
    }
}

Controller

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;

@RestController
public 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);
    }
}

2.消費者（引入feign框架）

技術分享圖片

pom.xml

<?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>

application.yml

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
@Setter
public class UserVO {
    private Integer userId;
    private String userName;
    private Date userBirth;
}

RestTemplate配置類

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;

@SpringBootConfiguration
public class RestTemplateConfiguration {

    @Bean
    @LoadBalanced // Ribbon 負載均衡
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }
}

Controller

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;

@RestController
public 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);
    }
}

使用框架的Controller

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;

@RestController
public class UserFeignController {
    @Resource
    private UserClient userClient;

    // 調用只有一個或者多個服務實例API的情況下
    @GetMapping("feign/user/{userId}")
    public UserVO getUserData(@PathVariable("userId") Integer userId) {
        return userClient.getUserData(userId);
    }
}

feign調用客戶端

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);
    }
}

總結起來，feign框架可以理解成路由，對url進行再次包裝後供給客戶端調用，可以在這個路由上進行一系列限制操作，增強安全性。

SpingCloud之feign框架調用

for type namespace tco war bind 消費 mode 生產者 1.生產者（沒有什麽特殊性） pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http

python之文件調用

color clas print .py cnblogs pat div class sys test_import_file.py，在當前目錄 import sys sys.path.append("..") import hello hello.printHell

TP框架調用ajax 以及分頁的引用

stat 之前 str 讀取 text 指向 spa 空間 ati thinkphp使用ajax和之前使用ajax的方法一樣，不同點在於之前的ajax中的url指向了一個頁面，而thinkphp裏面的url需要指向一個操作方法。一、thinkphp使用ajax返回數據

Quartz框架調用——運行報錯:ThreadPool class not specified

設置 adp 調用 quartz 例如 per 定義 pro bsp Quartz框架調用——運行報錯:ThreadPool class not specified 問題是在於Quartz框架在加載的時候找不到quartz.properties配置文件：解決方案一： Qu

前後分離模型之封裝 Api 調用

password 環境 word 簡單的 login 進行 func 一點項目 Ajax 和異步處理調用 API 訪問數據采用的 Ajax 方式，這是一個異步過程，異步過程最基本的處理方式是事件或回調，其實這兩種處理方式實現原理差不多，都需要在調用異步過程的時候傳入一個

django+salt 之初步實現調用命令

正常 blog 輸入技術 http 分享狀態內存 com 實驗了ansible和salt的執行速度相差太大了，後發現外網機器正常速度差不多，可能是虛擬機內存太小導致，後續查找問題使用django框架+layui布局，commands getstatusoutput來獲

Python之Suds庫調用WCF實現復雜參數序列化

rtu keyvalue microsoft ets tex sse exceptio https aps 今年主要做自動化測技術支持工作，最近一直在做接口自動化這塊,前些天在研究將web頁面模擬http進行接口自動化，這周杭州那邊想測試WCF服務,所以這兩天一直在探索。遇

Feign來調用服務

sta 創建解碼器分享客戶 spring bubuko 均衡 blog Feign是一個聲明式的偽Http客戶端，它使得寫Http客戶端變得更簡單。使用Feign，只需要創建一個接口並註解。它具有可插拔的註解特性，可使用Feign 註解和JAX-RS註解。Feign支

4.motan之集群調用

其它 zookeep fig 兩個 amp for 配置 ear inter 前言：在集群環境下使用Motan需要依賴外部服務發現組件，目前支持consul或zookeeper，但是工作中最常用的是zookeeper，所以這裏以zookeeper作為註冊中心 ! 一、zoo

Feign動態調用，結合Ribbon

balancer lee java value mark ali abc over factory 代碼如下，三種方法： import org.springframework.beans.factory.annotation.Autowired;import org.sp

java使用JNA框架調用dll動態庫

路徑 sta ... 情況下 build 官方 desc jna ace 這兩天了解了一下java調用dll動態庫的方法，總的有三種：JNI、JNA、JNative。其中JNA調用DLL是最方便的。 ·JNI ·JNA ·JNative java使用 JNI來

SpringCloud系列——Feign 服務調用

void ima 超時 ota log client 配置文件 string 瀏覽器　　前言　　前面我們已經實現了服務的註冊與發現（請戳：SpringCloud系列——Eureka 服務註冊與發現），並且在註冊中心註冊了一個服務myspring

如何全域性捕捉 eureka 通過 Feign 遠端調用出現的異常

萬事皆有因玩過 springcloud 的微服務架構的小夥伴們都知道，在我們通過 eureka 遠端呼叫其他的微服務的時候，防止網路抖動或者程式異常等情況，往往會加上 hystrix 斷路器對異常進

PWN菜雞入門之函數調用棧與棧溢出的聯系

sof cccccc ebp main函數程序 spa last lock 實例一、函數調用棧過程總結 Fig 1. 函數調用發生和結束時調用棧的變化 Fig 2. 將被調用函數的參數壓入棧內 Fig 3. 將被調用函數的返回地址壓入棧內 Fig

springcloud之Feign實現聲明式REST調用

web 服務器列表 from pub 模板客戶端 tap dep clas Feign是Netflix開發的聲明式、模板化的HTTP客戶端，可幫助我們更加便捷、優雅的調用HTTP api。spring cloud對Feign進行了增強，使Feign支持了Spring MV

Spring Cloud之Feign客戶端調用工具

port ont parent 中心 img pin reg mave mode feign介紹 Feign客戶端是一個web聲明式http遠程調用工具，提供了接口和註解方式進行調用。 Spring Cloud 支持 RestTemplate Fetin Feign客

.Net 之 RPC 框架之Hprose（遠程調用對象）

get 遠程跨進程 add nbsp list sin mes localhost 實現遠程調用對象，跨進程訪問對象，可實現分布式首先給服務端和客戶端 nuget Hprose 可使用tcp和http兩種調用方式服務端 using Hprose.Serve

vlc源碼分析之調用live555接收RTSP數據

sca loss 問題賦值 mage 轉載 linda 結構 mex 　　首先了解RTSP/RTP/RTCP相關概念，尤其是了解RTP協議：RTP與RTCP協議介紹（轉載）。　　vlc使用模塊加載機制調用live555，調用live555的文件是live555.cpp。

JVM 方法調用之動態分派

public super 1. 動態分派一個體現是重寫(override)。下面的代碼，運行結果很明顯。 1 public class App { 2 3 public static void main(String[] args) { 4 Super

python 之調用函數

abs last lin docs trac ive get targe type Python內置了很多有用的函數，我們可以直接調用。要調用一個函數，需要知道函數的名稱和參數，比如求絕對值的函數abs，只有一個參數。可以直接從Python的官方網站查看文檔： http:

SpingCloud之feign框架調用

1.生產者（沒有什麽特殊性）

2.消費者（引入feign框架）

相關推薦