代码地址

https://gitee.com/zjj19941/ZJJ_Dubbo.git

看dubbo-start-demo项目即可

搭建zookeeper

自己去博客随便弄个zookeeper安装教程.,然后启动起来

或者看我的博客,用docker快速搭建一个zookeeper起来,

https://blog.csdn.net/qq_41489540/article/details/109129293

pom文件

自己去我码云项目看一下,我就不粘贴了

https://gitee.com/zjj19941/ZJJ_Dubbo.git

看dubbo-start-demo项目即可

interface项目

DemoService

  1. package com.zjj;
  4. public interface DemoService {
  5.     // 同步调用方法
  6.     String sayHello(String name);
  8. }

服务的提供者

properties文件

  1. # Spring boot application
  2. spring.application.name=dubbo-provider-demo
  3. server.port=8081
  5. # Base packages to scan Dubbo Component: @org.apache.dubbo.config.annotation.Service
  6. #这个配置是扫描带有@org.apache.dubbo.config.annotation.Service注解的类,如果有的话,就解析这个注解的类
  7. #将配置信息进行处理,最后放到注册中心上面去.
  8. #你在类上面定义注解是没有用的,你得有配套的逻辑去识别定义这个注解的类
  9. #然后做一些别的处理
  10. dubbo.scan.base-packages=com.zjj.provider.service
  11. # dubbo需要定义你的应用名字
  12. dubbo.application.name=${spring.application.name}
  13. ## Dubbo 注册的注册中心地址
  14. dubbo.registry.address=zookeeper://zjj101:2181
  16. # Dubbo 协议定义,这个是属于应用级别的 ,配置你这个应用 用什么协议
  17. dubbo.protocol.name=dubbo
  18. dubbo.protocol.port=20880
  20. #dubbo.protocol.name=rest
  21. #dubbo.protocol.port=8083

提供服务的实现类

  1. package com.zjj.provider.service;
  3. import com.zjj.DemoService;
  4. import org.apache.dubbo.common.URL;
  5. import org.apache.dubbo.config.annotation.Service;
  6. import org.apache.dubbo.rpc.RpcContext;
  8. @Service(version = "default")
  9. public class DefaultDemoService implements DemoService {
  11.     @Override
  12.     public String sayHello(String name) {
  13.         System.out.println("执行了服务" + name);
  15.         URL url = RpcContext.getContext().getUrl();
  16.         return String.format("%s：%s, Hello, %s", url.getProtocol(), url.getPort(), name);  // 正常访问
  17.     }
  20. }

启动类

  1. package com.zjj;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. @SpringBootApplication
  7. public class DubboProviderDemo {
  9.     public static void main(String[] args) {
  10.         SpringApplication.run(DubboProviderDemo.class, args);
  11.     }
  12. }

服务的消费者

配置文件

  1. spring:
  2.   application:
  3.     name: dubbo-consumer-demo
  5. server:
  6.   port: 8082
  8. dubbo:
  9.   registry:
  10.     address: zookeeper://zjj101:2181

启动类

  1. package com.zjj;
  3. import org.apache.dubbo.config.annotation.Reference;
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. import org.springframework.context.ConfigurableApplicationContext;
  8. @SpringBootApplication
  9. public class DubboConsumerDemo  {
  11.   //@Reference注解就是用于标记这个服务具体使用了生产者的哪个接口实现
  12.     @Reference(version = "default")
  13.     private DemoService demoService;
  15.     public static void main(String[] args)  {
  16.         ConfigurableApplicationContext context = SpringApplication.run(DubboConsumerDemo.class);
  17.         DemoService demoService = context.getBean(DemoService.class);
  19.         System.out.println((demoService.sayHello("你好")));
  20.     }
  22. }

开始测试

先启动服务的提供者项目 ,再启动服务的消费者, 然后控制台就能看到,说明服务的消费者已经访问到了服务的发起方了.

  1. dubbo：20880, Hello, 你好

查看zookeeper,你会发现这个服务被注册到了注册中心上

image.png