Springcloud项目简单搭建四(服务消费者)

一时失言乱红尘 2021-11-09 14:22 334阅读 0赞

上篇文章中测试的时候我使用的postman来测试接口,现在我们要创建一个真正使用接口的服务.

# 创建项目 #

1.  首先在使用工具创建一个springboot项目 在pom中添加如下配置:

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

这里我们使用feign来访问我们想要的服务.

项目配置文件中我们启用feign的熔断功能,在application.yml中添加如下内容:

feign:
      hystrix:
        enabled: true

在项目启动类上添加注解,开启feign

@EnableFeignClients

# 使用feign调用其他服务 #

创建完成项目之后,我们看怎么来使用前面创建的pay-server服务中的内容

在前面创建的pay-server服务中创建了一个测试的可访问的方法:

@RestController
    @RequestMapping("pay")
    public class TestController {
    
        @RequestMapping("test")
        public JSONObject test(){
            JSONObject jsonObject = new JSONObject();
            jsonObject.put("test", "value1");
            return jsonObject;
        }
    
    }

我们现在通过刚出案件的website服务来调用此方法.

首先我们创建一个feign的调用接口创建如下,注解FeignClient来声明此接口是feign接口,里面的value参数代表着我们前面的pay-server服务注册到eureka中的服务名称.当然FeignClient也能通过地址来访问服务,但是我们有eureka注册中心了,通过服务名来访问服务可以实现负载均衡的能力,feign中存在着此能力.所以我们尽量使用此方式来进行服务间的访问.接口中的抽象方法上的注解,代表着我们要访问的服务中某个地址.也就是我们上面服务中的地址.

@FeignClient(value = "PAY-SERVER")
    public interface TestServiceFeign {
    
        @PostMapping(value = "/pay/test", consumes = "application/json")
        JSONObject test();
    
    }

现在创建controller如下:controller中注入此接口,然后调用接口中方法,进行测试.

@Controller
    public class TestController {
    
        @Resource
        private TestServiceFeign service;
    
        @RequestMapping("")
        @ResponseBody
        public JSONObject index(){
            return service.test();
        }
    
    
    }