配置文件application.yml,要注意的是registry.address的配置是广播模式:
dubbo: application: #application-name 本模块名字 name: springboot-multicast-provider id: springboot-multicast-provider registry: address: multicast://224.5.6.7:1234 id: registry protocol: name: dubbo port: 20880编写服务实现类DemoServiceImpl.java,注意@Service注解将当前类的实例作为远程服务对外暴露:
package com.bolingcavalry.springbootmulticastprovider; import com.bolingcavalry.dubbopractice.service.DemoService; import lombok.extern.slf4j.Slf4j; import org.apache.dubbo.config.annotation.Service; import org.apache.dubbo.rpc.RpcContext; @Slf4j @Service public class DemoServiceImpl implements DemoService { @Override public String sayHello(String name) { log.info("I'm springboot-multicast-provider, Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress()); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } return "I'm springboot-multicast-provider, Hello " + name + ", response from provider: " + RpcContext.getContext().getLocalAddress(); } }编写SpringBoot启动类SpringBootMulticastProviderApplication.java,注意要添加@EnableDubbo注解:
package com.bolingcavalry.springbootmulticastprovider; import org.apache.dubbo.config.spring.context.annotation.EnableDubbo; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication @EnableDubbo public class SpringBootMulticastProviderApplication { public static void main(String[] args) { SpringApplication.run(SpringBootMulticastProviderApplication.class, args); } }至此服务提供方编码完成,直接在IDEA上运行SpringBootMulticastProviderApplication类即可启动服务,启动成功后的日志输出如下图:
编码(服务消费方)现在网络上已经有了服务,咱们再来编写服用消费方的代码,一共要创建6个文件,创建顺序和功能如下表:
创建顺序 文件名 作用1 pom.xml 工程的pom文件
2 src/main/resources/application.yml 配置文件
3 RemoteInvokeServiceImpl.java service层,在这里远程调用服务提供方的服务
4 DemoController.java web接口类,对外提供web服务
5 SwaggerConfig.java swagger配置类,便于通过页面测试接口
6 SpringBootMulticastConsumerApplication.java 启动类
完整的文件位置如下图:
接下来逐个创建上述文件;
创建名为springbootmulticastconsumer的子工程,pom.xml内容如下,同样需要依赖dubbo-spring-boot-starter:
<?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 "> <parent> <artifactId>dubbopractice</artifactId> <groupId>com.bolingcavalry</groupId> <version>1.0-SNAPSHOT</version> </parent> <modelVersion>4.0.0</modelVersion> <groupId>com.bolingcavalry</groupId> <artifactId>springbootmulticastconsumer</artifactId> <version>1.0-SNAPSHOT</version> <name>springbootmulticastconsumer</name> <description>Demo project for dubbo service consumer from Spring Boot, multicast mode</description> <!--不用spring-boot-starter-parent作为parent时的配置--> <dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-dependencies</artifactId> <version>${springboot.version}</version> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!-- swagger依赖 --> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger2</artifactId> </dependency> <!-- swagger-ui --> <dependency> <groupId>io.springfox</groupId> <artifactId>springfox-swagger-ui</artifactId> </dependency> <dependency> <groupId>com.bolingcavalry</groupId> <artifactId>practiceinterface</artifactId> <version>${project.version}</version> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <version>${springboot.version}</version> </plugin> </plugins> </build> </project>