springcloud使用(三) 服务提供与消费

服务注册中心已经有了: 现在需要服务提供者和服务消费者
案例要求很简单: 消费者调用服务请求hello, 根据传入参数name, 实现返回"hello, name"即可

1. 搭建服务提供者producer

pom如下

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

配置application.properties

# 服务提供者
spring.application.name=spring-cloud-eureka-producer
server.port=9000
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

*取消了eureka.client.register-with-eureka 和eureka.client.fetch-registry的配置, 因为默认为true, 就是要将其注册到注册中心register

在项目启动类添加注解@EnableEurekaClient
编写服务

@RestController
public class ApiHello {
    /*@Autowired
    private LoadBalancerClient loadBalancerClient;*/

    @RequestMapping(value = "/hello")
    public String sayHello(HttpServletRequest request) throws IllegalAccessException {
        String name = request.getParameter("name");
        /*String age = request.getParameter("age");
        if(age.equals("23")){
            throw new IllegalAccessException("我出错了xox");
        }*/
//        System.out.println("我是9001");
        return JSON.toJSONString("hello,"+name);
    }
}

启动项目, 访问http://localhost:8000/, 注册应用出多了应用SPRING-CLOUD-EUREKA-PRODUCER
看见屏幕中间有一排红字不要慌, 那是告诉咱们没有消费者

小场面, 不要慌
再访问http://localhost:9000/hello?name=李四, 返回"hello,李四"说明服务正常, 开始搭建消费者

2. 搭建服务消费者consumer

pom如下, 和producer一样, 都依赖spring-cloud-starter-netflix-eureka-client

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

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

配置application.properties

# 服务消费者
spring.application.name=spring-cloud-eureka-consumer
server.port=9001
eureka.client.serviceUrl.defaultZone=http://localhost:8000/eureka/

在项目启动类添加注解@EnableEurekaClient, 和提供者一样
消费者代码
基于Ribbon,Ribbon是一个客户端的负载均衡器，它提供对大量的HTTP和TCP客户端的访问控制

@RestController
public class ApiHello {
    @Bean
    @LoadBalanced
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

    @Autowired
    private RestTemplate restTemplate;

    @RequestMapping(value = "/consumer/hello")
    public String hello(HttpServletRequest request) throws JsonProcessingException {
        String name = request.getParameter("name");
        MultiValueMap<String, String> map= new LinkedMultiValueMap<>();
        map.add("name",name);
        return this.restTemplate.postForObject("http://spring-cloud-eureka-producer/hello",map,String.class);
    }
}

启动消费者, 浏览器访问http://localhost:8000, 看见application出现了两个应用, 一个消费者, 一个提供者. 继续访问http://localhost:9001/consumer/hello?name=%E4%BD%A0%E6%98%AF%E5%82%BB%E5%AD%90, 如果出现"hello, 你是傻子", 说明服务和消费都正常

3. 负载均衡

在提供者的服务代码中加入打印port即可

@RestController
public class ApiHello {
    /*@Autowired
    private LoadBalancerClient loadBalancerClient;*/

    @RequestMapping(value = "/hello")
    public String sayHello(HttpServletRequest request) throws IllegalAccessException {
        String name = request.getParameter("name");
        /*String age = request.getParameter("age");
        if(age.equals("23")){
            throw new IllegalAccessException("我出错了xox");
        }*/
        System.out.println("我是9000");
        return JSON.toJSONString("hello,"+name);
    }
}

启动, 修改端口号比如9002, 打印语句也改成9002, 其他都不用改,打包启动
浏览器访问http://localhost:9001//consumer/hello?name=%E4%BD%A0%E6%98%AF%E5%82%BB%E5%AD%90, 分别在控制台能看见9000端口服务打印 我是9000, 9002端口服务打印 我是9002. 轮询调用, 这也就实现了负载均衡

4. 基于feign的服务消费者

Feign是一个声明式的伪Http客户端，它使得写Http客户端变得更简单。使用Feign，只需要创建一个接口并注解。它具有可插拔的注解特性，可使用Feign 注解和JAX-RS注解。Feign支持可插拔的编码器和解码器。Feign默认集成了Ribbon，并和Eureka结合，默认实现了负载均衡的效果

可以新建一个module, 也可以在前面的消费者上面改
pom中加入spring-cloud-starter-openfeign依赖

<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>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>

application.properties不变
启动类上注解如下

@SpringBootApplication
@EnableDiscoveryClient      // 启用服务注册与发现
@EnableFeignClients         // 启用feign进行远程调用

新建接口

@FeignClient(value ="spring-cloud-eureka-producer")
public interface  HelloService {
    @RequestMapping("/hello")
    String hello(@RequestParam(value = "map") Map<String,String> map);
}

controller调用该接口

@RestController
public class ApiHello {
    @Autowired
    HelloService helloService;

    @RequestMapping("/feign/hello")
    public String hello(HttpServletRequest request){
        String name = request.getParameter("name");
//        String age = request.getParameter("age");
        Map<String, String> map = new HashMap<>();
        map.put("name",name);
//        map.put("age",age);
        // 调用多个服务
        return helloService.hello(map);
    }
}

ok, 浏览器访问http://localhost:9003/feign/hello?name=%E6%9D%8E%E5%9B%9B, 结果正常即可, 当然feign也可以实现负载均衡, 启动两个服务提供者即可
over