- 1.新建PayService模块
- 2.定义接口模块
- 3.服务提供者
- 4.服务消费者：
- 5.启动生产者
- 6.启动消费者
这是我父工程的部分定义：
org.springframework.boot spring-boot-starter-parent 2.1.6.RELEASE cn.redocloud crazy 1.0 crazy Maven Webapp http://www.example.com UTF-8 1.8 1.8 UTF-8 UTF-8 2.1.5 Greenwich.SR2 0.9.0.RELEASE 2.7.1 org.projectlombok lombok true org.springframework.cloud spring-cloud-dependencies ${spring-cloud.version} pom import org.springframework.cloud spring-cloud-alibaba-dependencies ${spring-cloud-alibaba.version} pom import com.alibaba.cloud spring-cloud-alibaba-dependencies 2.1.0.RELEASE pom import
选中工程文件，如我这里是crazy=>new Moudule=>填写模块信息=>Finish
以下是common模块的部分内容：
因为我这里已经有了common模块，就将就用这个模块来定义dubbo服务的接口了
public interface PayService {
void pay(Map map);
}
项目结构如下：
定义玩接口后，执行maven的package或者install命令：
可以在自己的本地maven仓库中看到，common-1.0.jar
以下是payservice服务的内容
依赖如下：
crazy cn.redocloud 1.0 4.0.0 payservice cn.redocloud common 1.0 compile org.apache.dubbo dubbo-spring-boot-starter ${dubbo.version} org.apache.dubbo dubbo ${dubbo.version} org.apache.dubbo dubbo-registry-nacos ${dubbo.version} org.springframework.cloud spring-cloud-starter-alibaba-nacos-config org.springframework.cloud spring-cloud-starter-alibaba-nacos-discovery 8 8
application.yml配置：
spring:
profiles:
active: dev
application:
name: payservice
dubbo:
registry:
address: nacos://127.0.0.1:8848
##dubbo nacos 命名空间 默认public
parameters[namespace]: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
protocol:
port: -1
name: dubbo
bootstrap.yml配置
spring:
cloud:
nacos:
config:
namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
group: dev
server-addr: 127.0.0.1:8848
file-extension: yaml
discovery:
namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
server-addr: 127.0.0.1:8848
现在写一个服务类：
注意:此处的@Service为dubbo包下的注解而非Spring的注解
代码如下：
package cn.redocloud.service;
import cn.redocloud.api.PayService;
import lombok.extern.slf4j.Slf4j;
import org.apache.dubbo.config.annotation.Service;
import java.util.Map;
@Service
@Slf4j
public class PayServiceImpl implements PayService {
@Override
public void pay(Map map) {
log.info("数据为{}",map);
}
}
编写一个启动类
import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
//scanbasePackages 这个就是业务类所在的包路径 启动dubbo
@EnableDubbo(scanbasePackages = "cn.redocloud.service")
public class PayApplication {
public static void main(String[] args) {
SpringApplication.run(PayApplication.class,args);
}
}
4.服务消费者：
以下是uservice模块的内容：
依赖如下：
crazy cn.redocloud 1.0 4.0.0 cn.redocloud userservice 1.0 userservice Maven Webapp UTF-8 1.8 1.8 org.springframework.cloud spring-cloud-starter-alibaba-nacos-config org.springframework.cloud spring-cloud-starter-alibaba-nacos-discovery org.springframework.boot spring-boot-starter-web cn.redocloud common 1.0 compile org.apache.dubbo dubbo-spring-boot-starter ${dubbo.version} org.apache.dubbo dubbo ${dubbo.version} org.apache.dubbo dubbo-registry-nacos ${dubbo.version}
application.yml如下
server:
port: 9002
spring:
profiles:
active: dev
application:
name: userservice
dubbo:
registry:
address: nacos://127.0.0.1:8848
##dubbo nacos 命名空间 默认public
parameters[namespace]: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
protocol:
port: -1
name: dubbo
bootstrap.yml如下
spring:
cloud:
nacos:
config:
namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
group: dev
server-addr: 127.0.0.1:8848
file-extension: yaml
discovery:
namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
server-addr: 127.0.0.1:8848
controller中写一个调用payservice的
@RestController
@RequestMapping("/user")
public class UserController {
@Reference
PayService payService;
@RequestMapping("/pay")
public String pay() {
payService.pay(new HashMap());
return "ok";
}
}
编写启动类：
@SpringBootApplication
@EnableDubbo
public class UserServiceApplication {
public static void main(String[] args) {
SpringApplication.run(UserServiceApplication.class,args);
}
}
5.启动生产者
启动payservice:
可以在nacos中看到已经多了一个provider，说明生产者注册成功了
消费者启动成功后，查看nacos
可以看到多了两个服务，一个是consumer
另外一个是userservice,笔者自己以前公司的项目是用的SpringCloud Alibaba的部分内容，网关使用gateway（继承了均衡负载）、配置中心注册中心使用的nacos、服务间调用用的openfeign（集成了熔断和均衡）、外部调用一般用的别人的官方jar或者是用resttemplate去做调用、reids缓存等等，笔者也在疑惑，如果把nacos-discovery的依赖删除了，是否能将dubbo服务注册上去：
注释discovery的依赖：
启动：
消费者服务正常启动：
此次nacos上只多了一个consumer服务
同理，注释掉生产者payservice的discovery配置：
发现服务正常注册：
说明其实对于dubbo+nacos来说，只需要如下依赖即可：也就是说上面的内容中可以注释掉discovery的内容（因为配置中心还是应该要的，所以这里就没有去掉nacos-config的依赖）
org.apache.dubbo dubbo-spring-boot-starter ${dubbo.version} org.apache.dubbo dubbo ${dubbo.version} org.apache.dubbo dubbo-registry-nacos ${dubbo.version}
其他的就是你自己定义的接口和Spring等的一些包了
注意事项：
以上内容使用了nacos的配置中心，所以需要你在nacos中添加部分配置文件如我的：
其中data id的命名必须与你工程中的命名对应，如：
application.yml
spring:
profiles:
active: dev
application:
name: userservice
bootstrap.yml:
spring:
cloud:
nacos:
config:
namespace: 9eeffe66-d561-4b00-a42c-38d13fd5cd09
group: dev
server-addr: 127.0.0.1:8848
file-extension: yaml
那么你的配置文件的名字应该为：
userservice-dev.yaml （也就是application.name+profiles+file-extension的内容）并且需要严格区分namespace 和 group，file-extension为文件后缀名。
其他服务的配置以此类推。
访问接口：
payservice打印内容（因为我没有传值所以打印的酒就是括号）
dubbo的熔断机制：
在调用者这里实现一个熔断类（和FeignClient差不多）
@Slf4j
public class PayServiceFallback implements PayService {
@Override
public void pay(Map map) {
log.info("服务请求超时");
}
}
在@Refrence注解中设置：
@Reference(mock = "cn.redocloud.fallback;",cluster = "failfast")
PayService payService;
关闭payservice服务后，再次访问接口：
可以看到在fallback类的操作被执行了
