SpringBoot+Dubbo项目简单搭建实现斐波那契第n项

Posted 2022-06-13 PushyTao

这里写目录标题

• • step1 新建项目
  • step2 新建需要的包和接口以及实现类
  • step3 在两个项目的resource下新建配置文件
  • step4 代码编写
  • • 导入依赖
    • provider
    • consumer
    • 端口冲突更改
  • step5 运行

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"?>
<beans xmlns="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:application name="springboot-buddo-provider"/>
    <!-- 发布者 dubbo协议  -->
    <dubbo:protocol name="dubbo" port="20881"/>
    <!-- 定义bean -->
    <bean id="providerImpl" class="com.springdubbo.demo.springbootdubbo.apiImpl.ProviderImpl"/>
    <!-- dubbo服务 发布者发布服务  需要暴露的服务接口 -->
    <dubbo:service interface="com.springdubbo.demo.springbootdubbo.ServiceAPI" ref="providerImpl"
                   registry="N/A"/>
</beans>

consumer的该配置文件内写入：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="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:application name="springboot-buddo-consumer"/>
    <!-- 远程服务调用代理 -->
    <dubbo:reference id="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

package com.springdubbo.demo.springbootdubbo.apiImpl;

import com.alibaba.dubbo.config.annotation.Service;
import com.springdubbo.demo.springbootdubbo.ServiceAPI;

/**
 * @author wuyt
 * @data 2022/6/11
 * @apiNote
 */

@Service
public class ProviderImpl implements ServiceAPI 
    public String getMessage(String message) 
        return "springboot-dubbo-provider  =>>>>>" + message;
    
    public String getTheFeibN(int n) 
        //斐波那契数列第n项的实现逻辑
    

ServiceAPI

package com.springdubbo.demo.springbootdubbo;


/**
 * @author wuyt
 * @data 2022/6/11
 * @apiNote
 */

public interface ServiceAPI 
    public String getMessage(String message);
    public String getTheFeibN(int n);

SpringbootDubboApplication
一定要加上ImportResource注解

package com.springdubbo.demo.springbootdubbo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource("classpath:spring-dubbo.xml")
public class SpringbootDubboApplication 
    public static void main(String[] args) 
        SpringApplication.run(SpringbootDubboApplication.class, args);
    

consumer

ServiceAPI

package com.springdubbo.demo.springbootdubbo;

/**
 * @author wuyt
 * @data 2022/6/11
 * @apiNote
 */
public interface ServiceAPI 
    public String getMessage(String message);
    public String getTheFeibN(int n);

SpringbootDubboApplication

package com.springdubbo.demo.springbootdubbo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.ConfigurableApplicationContext;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@ImportResource("classpath:spring-dubbo.xml")
public class SpringbootDubboApplication 

	public static void main(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
结果：