Dubbo操作

admin控制台安装
- 控制台下载地址https://github.com/apache/incubator-dubbo/releases。
- 找到dubbo-admin。
- 修改webapp/WEB-INF/dubbo.properties。

- dubbo.registry.address=zookeeper的集群地址。
- 控制中心是用来做服务治理的，比如控制服务的权重、服务的路由。
simple监控中心
- 下载dubbo-monitor-simple-2.5.3-assembly.tar.gz包。
- 解压后到解压目录下的dubbo-monitor-simple-2.5.3\conf中找到dubbo.properties文件，修改成zookeeper注册中心地址。

- 点击bin目录下的start.bat启动，启动成功后，通过http://localhost:8080来访问监控中心。

- Monitor也是一个dubbo服务，所以也会有端口和url。
- 监控服务的调用次数、调用关系、响应事件。

简单实现的大概流程：

定义接口以及接口的实现类。
配置好Dubbo配置文件后，通过Main方法启动服务端，将服务暴露。

- 服务端配置文件：

 <?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:application name="order-provider" owner="provider"/>

     <dubbo:monitor protocol="registry"/>

     <!--dubbo这个服务所要暴露的服务地址所对应的注册中心--><!-- N/A:代表没有使用注册中心 -->

     <dubbo:registry protocol="zookeeper" address="47.107.121.215:2181"/>

     <!--当前服务发布所依赖的协议；webserovice、Thrift、Hessain、http-->

     <dubbo:protocol name="dubbo" port="20880"/>

     <!--服务发布的配置，需要暴露的服务接口-->

     <dubbo:service

             interface="com.karat.cn.order_api.IOrderServices"

             ref="orderService"/>

     <!--接口的实现  Bean bean定义-->

     <bean id="orderService"

     class="com.karat.cn.order_provider.OrderServiceImpl"/>

 </beans>

- Main方法：

 package com.karat.cn.order_provider;

 import com.alibaba.dubbo.container.Main;

 /**

  * Hello world!

  * 发布方法

  */

 public class App

 {

     public static void main( String[] args )

     {

         Main.main(args);

     }

 }

- 启动成功后日志中内容如下：

 2019-03-21 11:28:38,415 INFO [org.I0Itec.zkclient.ZkClient] - zookeeper state changed (SyncConnected)

 2019-03-21 11:28:38,416 INFO [com.alibaba.dubbo.registry.zookeeper.ZookeeperRegistry] -  [DUBBO] Register: dubbo://10.0.1.183:20880/com.karat.cn.order_api.IOrderServices?anyhost=true&application=order-provider&dubbo=2.5.3&interface=com.karat.cn.order_api.IOrderServices&methods=doOrder&owner=provider&pid=17524&side=provider&timestamp=1553138908571, dubbo version: 2.5.3, current host: 127.0.0.1

 2019-03-21 11:28:38,600 INFO [com.alibaba.dubbo.registry.zookeeper.ZookeeperRegistry] -  [DUBBO] Subscribe: provider://10.0.1.183:20880/com.karat.cn.order_api.IOrderServices?anyhost=true&application=order-provider&category=configurators&check=false&dubbo=2.5.3&interface=com.karat.cn.order_api.IOrderServices&methods=doOrder&owner=provider&pid=17524&side=provider&timestamp=1553138908571, dubbo version: 2.5.3, current host: 127.0.0.1

 2019-03-21 11:28:38,850 INFO [com.alibaba.dubbo.registry.zookeeper.ZookeeperRegistry] -  [DUBBO] Notify urls for subscribe url provider://10.0.1.183:20880/com.karat.cn.order_api.IOrderServices?anyhost=true&application=order-provider&category=configurators&check=false&dubbo=2.5.3&interface=com.karat.cn.order_api.IOrderServices&methods=doOrder&owner=provider&pid=17524&side=provider&timestamp=1553138908571, urls: [empty://10.0.1.183:20880/com.karat.cn.order_api.IOrderServices?anyhost=true&application=order-provider&category=configurators&check=false&dubbo=2.5.3&interface=com.karat.cn.order_api.IOrderServices&methods=doOrder&owner=provider&pid=17524&side=provider&timestamp=1553138908571], dubbo version: 2.5.3, current host: 127.0.0.1

 2019-03-21 11:28:38,933 INFO [com.alibaba.dubbo.container.Main] -  [DUBBO] Dubbo SpringContainer started!, dubbo version: 2.5.3, current host: 127.0.0.1

 [2019-03-21 11:28:38] Dubbo service server started!

- 第二行的：dubbo://10.0.1.183:20880/com.karat.cn.order_api.IOrderServices 是后面需要用到的服务url地址，使用zookeeper也是让zookeeper来管理这个东西。

- 消费端通过Dubbo配置文件调用服务端服务：

 <?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:application name="order-provider" owner="provider"/>

     <!--dubbo这个服务所要暴露的服务地址所对应的注册中心--><!-- N/A:代表没有使用注册中心 -->

     <!--

         配置集群地址： <dubbo:registry address="zookeeper://192.168.11.129:2181?backup=192.168.11.137:2181,192.168.11.138:2181,192.168.11.139:2181"/>

       -->

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

     <!--生成一个远程服务的调用代理--><!--引用一个服务 通过url关联 -->

     <dubbo:reference id="orderServices"

                 interface="com.karat.cn.order_api.IOrderServices"/>

     <!-- 使用zookeeper注册中心后不需要下面的url了，在zookeeper中能拿到url -->

     <!-- url="dubbo://10.0.1.183:20880/com.karat.cn.order_api.IOrderServices" -->

 </beans>

- 消费端测试：

public static void main( String[] args ) throws IOException {

        ClassPathXmlApplicationContext context=new ClassPathXmlApplicationContext("order-consumer.xml");

        //用户下单过程

        IOrderServices services=(IOrderServices)context.getBean("orderServices");

        DoOrderRequest request=new DoOrderRequest();

        request.setName("Hello world!");

        DoOrderResponse response=services.doOrder(request);

        System.out.println(response);

    }

- 消费端的pom中需要引入服务端项目打包成的jar包。

 <dependencies>

     <dependency>

       <groupId>junit</groupId>

       <artifactId>junit</artifactId>

       <version>3.8.1</version>

       <scope>test</scope>

     </dependency>

     <dependency>

       <groupId>com.karat.cn</groupId>

         <artifactId>order_api</artifactId>

         <version>0.0.1-SNAPSHOT</version>

       <scope>C:\Users\devel\Desktop\aa.jar</scope>

     </dependency>

     <dependency>

       <groupId>com.alibaba</groupId>

       <artifactId>dubbo</artifactId>

       <version>2.5.3</version>

     </dependency>

     <dependency>

         <groupId>com.github.sgroschupf</groupId>

         <artifactId>zkclient</artifactId>

         <version>0.1</version>

     </dependency>

   </dependencies>

invoker：cmd中Dubbo调用命令

巴特西

Dubbo操作

最新文章

热门文章