Feign

Eureka

pom

		<dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>

解释

只有Eureka是服务端，其他的都是客户端。

目录结构

JKEurekaApplication

springboot项目的启动类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

/**
 * @author The Phoenix(不死人)
 * @version 1.0
 * @date 2020/3/20
 */
@SpringBootApplication      //spring boot
@EnableEurekaServer         //注册中心服务
public class JKEurekaApplication {
    
    public static void main(String[] args) {
    
        SpringApplication.run( JKEurekaApplication.class , args );
    }
}

application.yml

里边eureka的配置只是临时的，不是最优，这个需要经过大佬的测试配置，这个以后再优化，只是能跑起来。

#eureka端口号
server:
  port: 10086
#eureka服务的名字
spring:
  application:
    name: jkeureka
#eureka服务
eureka:
  server:
    enable-self-preservation: false # Eureka自我保护机制，true打开/false禁用，默认打开状态，建议生产环境打开此配置。
    eviction-interval-timer-in-ms: 5000 # 修改检查失效服务的时间
  client:
    fetch-registry: false # 定期的更新客户端的服务清单，以保证服务访问的正确性
    register-with-eureka: false # 是否将自己注册为服务
    service-url:
      defaultZone: http://127.0.0.1:${
    server.port}/eureka # eureka服务的开放地址

服务提供方

目录结构

pom

提供反不需要导入feign坐标

<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>

MemberApplication

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;

@SpringBootApplication
@EnableDiscoveryClient      //eureka客户端
public class MemberApplication {
    
    public static void main(String[] args) {
    
        SpringApplication.run(MemberApplication.class, args);
    }
}

application.yml

#端口号
server:
  port: 7070

spring:
  application:
    name: memberservice   #服务名
  datasource:           #数据源配置
    url: jdbc:mysql://127.0.0.1:3306/jk_source?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
    username: root
    password: 12
    druid:              #druid连接池配置
      initial-size: 5
      min-idle: 5
      max-active: 20
      max-wait: 1000
      test-on-borrow: true
#配置eureka(注册中心)
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka
  instance:
    prefer-ip-address: true
    ip-address: 127.0.0.1
    instance-id: ${
    eureka.instance.ip-address}.${
    server.port}
    lease-renewal-interval-in-seconds: 3
    lease-expiration-duration-in-seconds: 10

MemberArchivesController

import com.czxy.jk.BaseResult;
import com.czxy.jk.common.Page;
import com.czxy.jk.member.MemberArchivesApi;
import com.czxy.jk.member.MemberProfile;
import com.czxy.jk.service.MemberArchivesService;
import com.github.pagehelper.PageInfo;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.UUID;

@RestController
@RequestMapping("/member")
public class MemberArchivesController {
    
    //服务调用方 会根据 远程调用得到对应的controller
    @PostMapping("/loginPhon")
    public MemberProfile loginPhon(@RequestBody MemberProfile memberProfile) {
    
        return memberArchivesService.loginPhon(memberProfile);
    }
}

服务调用方

目录结构

pom

必须要有的

		<!--eureka客户端-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>
        <!--feign远程调用-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>

LoginApplication

@SpringBootApplication //springBoot配置注解
@EnableEurekaClient // 开启eureka客户端
@EnableFeignClients // 开启远程调用
public class LoginApplication {
    
    public static void main(String[] args) {
    
        SpringApplication.run(LoginApplication.class , args);
    }
}

application.yml

#端口号
server:
  port: 9090

spring:
  application:
    name: loginservice   #服务名
  datasource:           #数据源配置
    url: jdbc:mysql://127.0.0.1:3306/自己的数据库?useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
    username: root
    password: 12
    druid:              #druid连接池配置
      initial-size: 5
      min-idle: 5
      max-active: 20
      max-wait: 1000
      test-on-borrow: true
#配置eureka(注册中心) 不是最优 谅解 以后会更新
eureka:
  client:
    service-url:
      defaultZone: http://127.0.0.1:10086/eureka
  instance:
    prefer-ip-address: true
    ip-address: 127.0.0.1
    instance-id: ${
    eureka.instance.ip-address}.${
    server.port}
    lease-renewal-interval-in-seconds: 3
    lease-expiration-duration-in-seconds: 10

LoginService

package com.czxy.jk.service;

import com.jk.dao.LoginMapper;
import com.jk.feign.FeignMember;
import com.jk.login.Login;
import com.jk.member.MemberProfile;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class LoginService {
    

    @Resource
    private FeignMember feignMember;


    public Login loginPhon(Login login) {
    
        MemberProfile memberProfile = new MemberProfile();
        memberProfile.setPhone(login.getPhone());
        // 远程调用 
        MemberProfile m = feignMember.loginPhon(memberProfile);
        Login l = new Login();
        l.setUsername(m.getName());
        return l;
    }
}

FeignMember

package com.jk.feign;

import com.jk.member.MemberProfile;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;

/**
 * value 是服务提供方的服务名
 * path 服务提供方的 @RequestMapping("/member") 这个是作用在方法上的
 *
 *
 */
@FeignClient(value="memberservice",path = "/member")
public interface FeignMember {
    

    // 要和服务提供方 一么一样 建议复制方法 在修改成抽象方法
    @PostMapping("/loginPhon")
    public MemberProfile loginPhon(@RequestBody MemberProfile memberProfile);
}

关系

提供方的 @RequestMapping("/member") 这个是作用在方法上的
*
*
*/
@FeignClient(value=“memberservice”,path = “/member”)
public interface FeignMember {

// 要和服务提供方 一么一样 建议复制方法 在修改成抽象方法
@PostMapping("/loginPhon")
public MemberProfile loginPhon(@RequestBody MemberProfile memberProfile);

}

# 关系
![在这里插入图片描述](https://img-blog.csdnimg.cn/2020083110310982.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NDYwNTU0Mw==,size_16,color_FFFFFF,t_70#pic_center)