Dubbo测试代码(二)

Love The Way You Lie 2022-06-01 00:20 170阅读 0赞

我创建了4个Maven工程  
parent（pom）和3个modul

dubbo-api   //服务端和消费端共用的接口工程
    dubbo-consumer //消费端
    dubbo-parent  //父工程 提供jar
    dubbo-provider  //服务端

我事先配好了SSM Web工程 当然你也可以写单元测试 进行测试

所用的maven依赖：  
父工程：

//除去SSM和连接池  log4j  等等的   dubbo必须的依赖
    
    
            
             <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>dubbo</artifactId>
                <version>2.5.3</version>
                <exclusions>
                    <exclusion>
                        <artifactId>spring</artifactId>
                        <groupId>org.springframework</groupId>
                    </exclusion>
                </exclusions>
            </dependency>
    
            
            <dependency>
                <groupId>org.apache.zookeeper</groupId>
                <artifactId>zookeeper</artifactId>
                <version>3.3.6</version>
                <exclusions>
                    <exclusion>
                        <groupId>log4j</groupId>
                        <artifactId>log4j</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency> 
                <groupId>com.101tec</groupId>
                <artifactId>zkclient</artifactId>
                <version>0.10</version>
            </dependency>

其次 consumer工程和provider工程 都要添加 公共的接口api依赖：

<dependency>
              <groupId>dubbo-demo</groupId>
              <artifactId>dubbo-api</artifactId>
              <version>0.0.1-SNAPSHOT</version>
        </dependency>

此时 我模拟RPC调用  
web 网页发起请求 进入Consumer工程 查询学生列表  
consumer工程 调用服务 provider工程 提供服务 返回学生list 给consumer工程 ：

代码如下：

**1.接口工程 编写接口程序:**

package cn.dubbo.interf;
    
    import java.util.List;
    
    public interface UserService { 
    
        public List findStuNameById(String stuId);  //我这里根据一个id 查出一堆学生 不要在意细节
    
    }

**2.服务端工程代码：**

package cn.dubbo.controller;
    
    import java.util.ArrayList;
    import java.util.List;
    
    import org.springframework.stereotype.Service;
    
    import cn.dubbo.interf.UserService;
    
    @Service("userService")
    public class UserServiceImpl implements UserService{ 
    
        @Override
        public List findStuNameById(String stuId) {
            List<String>  stuList = new ArrayList<String>();
            stuList.add("何睿");
            stuList.add("张三");
            return stuList;
        }   
    
    }

**其次 添加dubbo服务端配置文件 注意添加 schema 约束头文件**

**服务端干了两件事 第一 实现接口工程的方法 ，对接口方法做出业务的实现。第二件 配置文件中 向注册中心注册服务 并给出dubbo:service 中的ref =”\#”（相当于bean id= \# > /bean>） 以及接口**

**3.客户端代码：**

package cn.dubbo.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import cn.dubbo.interf.UserService;
    
    @Controller
    public class StuController {
    
        @Autowired
        private UserService userService;
    
    
        @RequestMapping("/name")
        @ResponseBody
        public List find1(){
            return  userService.findStuNameById("1");
        }
    
    }

**客户端配置文件**

**客户端 就干了一件事： 向注册中心订阅服务，将UserService的实现类 以userService的名称 注入Controller中。即可完成远程调用。**

**启动细节：**  
首先启动服务之前 先启动zookeeper zookeeper的配置不多说了  
如果是单机 就是

<dubbo:registry address="zookeeper://localhost:2181"/>

如果是集群 就是

<dubbo:registry  address="zookeeper://node1:2181,node2:2181,node3:2181"/>
    //多插一句嘴 肯定是奇数个节点 保证选举正常

**要知道 启动完zookeeper应该先启动服务端project，然后在启动consumer端的工程，否则Spring会报错，那么问题：如果 有一个核心工程 和另一个核心工程 两个互相调用 怎么办呢？**

如果互相调用 可以在提供一个配置文件 将服务端/消费端 的配置写入 即可 ，注意：**application 只能有一个**  
两个工程互相调用 就是配置项的东西了  
**check=”false” 在订阅服务时不检查 服务端是否提供服务。**

另附上 dubbo web监控界面  
需要 dubbo-admin工程 github上下载 [https://github.com/alibaba/dubbo][https_github.com_alibaba_dubbo]

进入 dubbo-admin 目录 打包：

> mvn package -Dmaven.skip.test=true

打包成功后：把dubbo-admin-2.5.4-SNAPSHOT.war放到tomcat的webapps目录下  
我改成了dubbo  
修改tomcat 端口 不要是8080 我改成8090 因为zookeeper jetty管理窗口是 8080 防止冲突