第一次整合,使用无注册中心方式
一、首先,项目分为三个模块,如下图,dubbo-interface(要发布的接口)、dubbo-provider(接口的具体实现,服务提供者)、dubbo-consumer(客户端,服务消费者)
二、dubbo-interface模块,普通的springboot项目,只需要写接口,即需要向外提供的服务接口
如上图中的UserService。
三、dubbo-provider模块,它是dubbo-interface模块中接口的具体实现,服务提供者。
3.1、pom.xml文件
org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-web com.xice.dubbo dubbo-interface 0.0.1-SNAPSHOT io.dubbo.springboot spring-boot-starter-dubbo 1.0.0
3.2、application.properties文件,配置dubbo
server.port=8080
spring.dubbo.application.name=dubbo-provider
# N/A表示不使用注册中心
spring.dubbo.registry.address=N/A
# dubbo协议
spring.dubbo.protocol.name=dubbo
# duboo端口号
spring.dubbo.protocol.port=20882
# 发布到dubbo的接口所在包位置
spring.dubbo.scan=com.xice.dubbo
3.3、接口具体实现
/*** @author xice* @date 2022-11-14*/
@Service(version = "1.0.0")
public class UserServiceImpl implements UserService {SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");@Overridepublic String say(String username, String msg) {return username + " say: "+msg+" --"+dateFormat.format(new Date());}
}
四、dubbo-consumer客户端,服务消费者。
4.1、pom.xml文件与服务端一样,需要引入dubbo-interface模块、dubbo
org.springframework.boot spring-boot-starter org.springframework.boot spring-boot-starter-web com.xice.dubbo dubbo-interface 0.0.1-SNAPSHOT io.dubbo.springboot spring-boot-starter-dubbo 1.0.0
4.2、application.properties文件,配置dubbo,spring.dubbo.scan包可不完全一样,比如
# 应用名称
server.port=8099
spring.dubbo.application.name=dubbo-consumer
# N/A表示不使用注册中心
spring.dubbo.registry.address=N/A
# 发布到dubbo的接口所在包位置
spring.dubbo.scan=com.xice.dubbo
4.3、调用服务,注入UserService时不是使用SpringBoot中的@Autowired,而是使用@Reference (com.alibaba.dubbo.config.annotation.Reference),其中version为dubbo-provider服务中的版本号,url为服务提供者的ip和配置的端口号
/*** @author xice* @date 2022-11-15*/
@RestController
public class UserController {@Reference(version = "1.0.0",url = "dubbo://127.0.0.1:20882")UserService userService;@RequestMapping("say")public String say(){String say = userService.say("admin", "早上好");System.out.println(say);return say;}
}
五、先启动dubbo-provider、再启动dubbo-consumer,需要按顺序启动!如果先启动客户端就无法调用到服务。启动后访问客户端http://localhost:8099/say