Spring Cloud(微服务)学习篇(三)

1 nacos中使用openFeign(调用方式)实现短信发送

1.1 在shop-sms-api中创建com.zlz.shop.sms.api.service/vo/dto/util,目录结构如下所示

在这里插入图片描述

1.2 在pom.xml(shop-sms-api)中加入如下依赖

<dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <!--openFeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
</dependencies>

1.3 在service包下创建SmsService接口

package com.zlz.shop.sms.api.service;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;

//一个服务对应一个接口,api是给别人的
@FeignClient("shop-sms") //填写注册中心微服务的名称,这里与application中的yml文件(server那里的)中的application.name名字一致
public interface SmsService {
    //根据定义的控制器方法来写接口,和server里面的SmsController是保持一致的
    @RequestMapping("send")
    String send();
}

1.4 把父项目(shop-sms)打包到本地仓库(只需要打包一次)

1.4.1 找到shop-sms项目➡双击install按钮

在这里插入图片描述

1.4.2 打包成功的界面

在这里插入图片描述

1.5 把子项目shop-sms-api打包到本地仓库

1.5.1 找到shop-sms-api项目➡双击install按钮

在这里插入图片描述

1.5.2 打包成功的界面

在这里插入图片描述

1.6 在子项目中shop-sms-server的pom.xml中引入短信验证模块

1.6.1 引入短信验证模块代码

 <!--引入短信接口模块-->
 <dependency>
     <groupId>com.zlz</groupId>
     <artifactId>shop-sms-api</artifactId>
     <version>1.0</version>
 </dependency>

1.6.2 完整的pom.xml文件(shop-sms-server)如下所示

<?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">
    <parent>
        <artifactId>shop-sms</artifactId>
        <groupId>com.zlz</groupId>
        <version>1.0</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>shop-sms-api</artifactId>
    <dependencies>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <!--openFeign-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-openfeign</artifactId>
        </dependency>
    </dependencies>
</project>

1.7 在UserStart类中(shop-sms-server项目)加上注解

1.7.1 加入的注解代码

//开启openFeign
@EnableFeignClients

1.7.2 完整的UserStart类代码

package com.zlz;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.client.loadbalancer.LoadBalanced;
import org.springframework.cloud.openfeign.EnableFeignClients;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
@EnableDiscoveryClient //开启服务的注册和发现
//开启openFeign
@EnableFeignClients
public class UserStart {
    public static void main(String[] args) {
        SpringApplication.run(UserStart.class);
    }
    //这个负载均衡不用管,是redisTemplate方式的
    @Bean
    @LoadBalanced //Ribbon 负载均衡
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }

}

1.8 变更UserController类

1.8.1 在里面加入如下代码

 //使用oepnFeign的方式发送短信
    @Autowired
    SmsService smsService;
    @RequestMapping("test2")
    public String t2(){
        //http://shop-sms/send
        String s=smsService.send();
        return "用户服务调用短信服务 结果:"+s;
    }

1.8.2 完整的UserController类

package com.zlz.controller;

import com.zlz.shop.sms.api.service.SmsService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class UserController {
    @Autowired
    RestTemplate restTemplate;
    @RequestMapping("test")
    public String t(){
        //http://shop-sms/send
        String s=restTemplate.postForObject("http://shop-sms/send", null, String.class);
//        String s=restTemplate.postForObject("http://127.0.0.1:8021/send", null, String.class);
        return "用户服务调用短信服务 结果:"+s;
    }
    //★★★★★★使用oepnFeign的方式发送短信★★★★★★
    @Autowired
    SmsService smsService;
    @RequestMapping("test2")
    public String t2(){
        //http://shop-sms/send
        String s=smsService.send();
        return "用户服务调用短信服务 结果:"+s;
    }
}