这里写目录标题
step1 新建项目
方法1:直接在IDEA里新建如图:
方法2:在start.spring.io新建
可能有的小朋友已经发现了,第一种方式的Server URL就是第二个的网站,都是一样的
要新建两个项目,第一个项目如上图所示,第二个项目只需要将provider改为consumer
其余不变,解压后通过IDEA打开
step2 新建需要的包和接口以及实现类
provider 项目结构:
consumer 项目结构:
请注意,两个ServiceAPI在项目中的的所在位置,或者说包名要严格一致,否则后续会出问题
如果不一致,可以按照如下方式按需进行更改
xsd放到指定目录下:
C:\Users\用户名\.lemminx\cache\http\code.alibabatech.com\schema\dubbo
文件:
dubbo.xsd
下载链接:
「dubbo.xsd」https://www.aliyundrive.com/s/JN8dCuDH3XF
点击链接保存,或者复制本段内容,打开「阿里云盘」APP ,无需下载极速在线查看,视频原画倍速播放。
step3 在两个项目的resource下新建配置文件
需要新建的名字为:
spring-dubbo.xml
provider的该配置文件中写入:
<?xml version="1.0" encoding="UTF-8"?><beansxmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><!-- dubbo应用名称 --><dubbo:applicationname="springboot-buddo-provider"/><!-- 发布者 dubbo协议 --><dubbo:protocolname="dubbo"port="20881"/><!-- 定义bean --><beanid="providerImpl"class="com.springdubbo.demo.springbootdubbo.apiImpl.ProviderImpl"/><!-- dubbo服务 发布者发布服务 需要暴露的服务接口 --><dubbo:serviceinterface="com.springdubbo.demo.springbootdubbo.ServiceAPI"ref="providerImpl"registry="N/A"/></beans>
consumer的该配置文件内写入:
<?xml version="1.0" encoding="UTF-8"?><beansxmlns="http://www.springframework.org/schema/beans"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><!-- dubbo应用名称 --><dubbo:applicationname="springboot-buddo-consumer"/><!-- 远程服务调用代理 --><dubbo:referenceid="consumerImpl"interface="com.springdubbo.demo.springbootdubbo.ServiceAPI"url="dubbo://localhost:20881"/></beans>
step4 代码编写
导入依赖
在两个项目的pom.xml下均添加依赖:
<dependency>
<groupId>com.alibaba.spring.boot</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.0.0</version>
</dependency>
provider
ProviderImpl
Service注解一定不要忘记加,而且一定要是dubbo的Service
packagecom.springdubbo.demo.springbootdubbo.apiImpl;importcom.alibaba.dubbo.config.annotation.Service;importcom.springdubbo.demo.springbootdubbo.ServiceAPI;/**
* @author wuyt
* @data 2022/6/11
* @apiNote
*/@ServicepublicclassProviderImplimplementsServiceAPI{publicStringgetMessage(String message){return"springboot-dubbo-provider =>>>>>"+ message;}publicStringgetTheFeibN(int n){//斐波那契数列第n项的实现逻辑}}
ServiceAPI
packagecom.springdubbo.demo.springbootdubbo;/**
* @author wuyt
* @data 2022/6/11
* @apiNote
*/publicinterfaceServiceAPI{publicStringgetMessage(String message);publicStringgetTheFeibN(int n);}
SpringbootDubboApplication
一定要加上ImportResource注解
packagecom.springdubbo.demo.springbootdubbo;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.context.annotation.ImportResource;@SpringBootApplication@ImportResource("classpath:spring-dubbo.xml")publicclassSpringbootDubboApplication{publicstaticvoidmain(String[] args){SpringApplication.run(SpringbootDubboApplication.class, args);}}
consumer
ServiceAPI
packagecom.springdubbo.demo.springbootdubbo;/**
* @author wuyt
* @data 2022/6/11
* @apiNote
*/publicinterfaceServiceAPI{publicStringgetMessage(String message);publicStringgetTheFeibN(int n);}
SpringbootDubboApplication
packagecom.springdubbo.demo.springbootdubbo;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;importorg.springframework.context.ConfigurableApplicationContext;importorg.springframework.context.annotation.ImportResource;@SpringBootApplication@ImportResource("classpath:spring-dubbo.xml")publicclassSpringbootDubboApplication{publicstaticvoidmain(String[] args){ConfigurableApplicationContext count =SpringApplication.run(SpringbootDubboApplication.class, args);ServiceAPI impl =(ServiceAPI)count.getBean("consumerImpl");// System.out.println(impl.getMessage("Hello dubbo"));System.out.println(impl.getTheFeibN(10));}}
端口冲突更改
可以修改provider或者是consumer其中任意一个的端口号
这里修改consumer运行的端口号:
step5 运行
首先运行provider,然后运行consumer
结果:
版权归原作者 PushyTao 所有, 如有侵权,请联系我们删除。