分布式框架之通过Dubbo来实现服务消费方远程调用服务提供方的方法

Posted 2021-09-07 EijoaHoaiQ:D

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了分布式框架之通过Dubbo来实现服务消费方远程调用服务提供方的方法相关的知识，希望对你有一定的参考价值。

四、通过Dubbo来实现服务消费方远程调用服务提供方的方法

4.1 Dubbo管理控制台

我们在开发时，需要知道Zookeeper注册中心都注册了哪些服务，有哪些消费者来消费这些服务。
我们可以通过部署一个管理中心来实现查看这些服务，其实也就是将管理中心这个web应用部署到tomcat上即可。

方法一（一般兼容jdk1.8及以下版本）

将自己下载的资料中的dubbo-admin-2.6.0.war文件复制到tomcat的webapps目录下；
启动tomcat，此时war文件会自动解压；

修改WEB-INF下的dubbo.properties文件，注意dubbo.registry.address对应的值需要对应当前使用的

Zookeeper的ip地址和端口号
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.admin.root.password=root
dubbo.admin.guest.password=guest

重启tomcat
访问http://localhost:8080/dubbo-admin-2.6.0/，输入用户名(root)和密码(root)，启动成功。

方法二（兼容jdk1.8及以上版本）

下载并解压dubbo-admin-master-0.2.0包；
win+R进入dubbo-admin-master-0.2.0下的dubbo-admin目录下将此项目清理并打成jar包：
```
mvn clean package
```
等待加载后（第一次可能会有点慢）：
进入目录：\\dubbo-admin-master-0.2.0\\dubbo-admin\\target下会发现已经将此项目打好包了：

将此jar包复制出来（以便后面启动使用），和zookeeper包放在同一目录F:\\Code\\dubbo下：
win+R进入F:\\Code\\dubbo目录，执行命令：
```
java -jar dubbo-admin-0.0.1-SNAPSHOT.jar
```
注意：这个jar包是依赖于zookeeper的，启动之前必须先启动zookeeper。

4.2 nginx反向代理

正向代理代理客户端，反向代理代理服务器。

反向代理，其实客户端对代理是无感知的，因为客户端不需要任何配置就可以访问，我们只需要将请求发送到反向代理服务器，由反向代理服务器去选择目标服务器获取数据后，在返回给客户端，此时反向代理服务器和目标服务器对外就是一个服务器，暴露的是代理服务器地址，隐藏了真实服务器IP地址。

nginx反向代理就是通过自己设置的域名来随机访问不同的服务器，也就是由之前的localhost:8080/的访问形式改变成：www.baidu.com的访问形式。

在使用nginx反向代理时，进入nginx目录下输入：start nginx命令即可：

4.3 负载均衡

负载均衡（Load Balance）：其实就是将请求分摊到多个操作单元上进行执行，从而共同完成工作任务。
在集群负载均衡时，Dubbo 提供了多种均衡策略（包括随机、轮询、最少活跃调用数、一致性Hash），默认为random随机调用。
配置负载均衡策略，既可以在服务提供者一方配置，也可以在服务消费者一方配置，但是一般不建议在消费方配置，因为还不够灵活。
可以通过启动多个服务提供者来观察Dubbo负载均衡效果。

注意：因为我们是在一台机器上启动多个服务提供者，所以需要修改tomcat的端口号和Dubbo服务的端口号来防止端口冲突。
在实际生产环境中，多个服务提供者是分别部署在不同的机器上，所以不存在端口冲突问题。

4.4 服务提供方开发

创建maven工程：dubbodemo_provider（打包方式为war），并在pom.xml文件中导入相关依赖：

<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  <modelVersion>4.0.0</modelVersion>
  <!--项目的坐标gav-->
  <groupId>cn.dubbodemo_provider</groupId>
  <artifactId>dubbodemo_provider</artifactId>
  <version>1.0-SNAPSHOT</version>
  <packaging>war</packaging>
  <name>dubbodemo_provider Maven Webapp</name>
  <!-- FIXME change it to the project's website -->
  <url>http://www.example.com</url>
    <!--统一管理版本号-->
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>9</maven.compiler.source>
        <maven.compiler.target>9</maven.compiler.target>
        <spring.version>5.0.5.RELEASE</spring.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-beans</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-webmvc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jms</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${spring.version}</version>
        </dependency>
        <!-- dubbo相关 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>dubbo</artifactId>
            <version>2.6.0</version>
        </dependency>
        <!--注册中心zookeeper-->
        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.7</version>
        </dependency>
        <dependency>
            <groupId>com.github.sgroschupf</groupId>
            <artifactId>zkclient</artifactId>
            <version>0.1</version>
        </dependency>
        <dependency>
            <groupId>javassist</groupId>
            <artifactId>javassist</artifactId>
            <version>3.12.1.GA</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.47</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>
    </dependencies>
  <build>
      <plugins>
          <plugin>
              <groupId>org.apache.tomcat.maven</groupId>
              <artifactId>tomcat7-maven-plugin</artifactId>
              <version>2.2</version>
              <configuration>
                  <!-- 指定端口 -->
                  <port>8081</port>
                  <!-- 请求路径 -->
                  <path>/</path>
              </configuration>
          </plugin>
      </plugins>
    <finalName>dubbodemo_provider</finalName>
    <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->
      <plugins>
        <plugin>
          <artifactId>maven-clean-plugin</artifactId>
          <version>3.1.0</version>
        </plugin>
        <!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging -->
        <plugin>
          <artifactId>maven-resources-plugin</artifactId>
          <version>3.0.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-compiler-plugin</artifactId>
          <version>3.8.0</version>
        </plugin>
        <plugin>
          <artifactId>maven-surefire-plugin</artifactId>
          <version>2.22.1</version>
        </plugin>
        <plugin>
          <artifactId>maven-war-plugin</artifactId>
          <version>3.2.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-install-plugin</artifactId>
          <version>2.5.2</version>
        </plugin>
        <plugin>
          <artifactId>maven-deploy-plugin</artifactId>
          <version>2.8.2</version>
        </plugin>
      </plugins>
    </pluginManagement>
  </build>
</project>

配置web.xml文件

<!DOCTYPE web-app PUBLIC
        "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
        "http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:applicationContext-service.xml</param-value>
  </context-param>
  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
</web-app>

创建服务接口

package cn.dubbo.service;
public interface HelloService {
    public String sayHello(String name);
}

创建服务接口的实现类

package cn.dubbo.service.impl;
import cn.dubbo.service.HelloService;
import com.alibaba.dubbo.config.annotation.Service;
@Service(loadbalance = "roundrobin",interfaceClass = HelloService.class)
public class HelloServiceImpl implements HelloService {
    @Override
    public String sayHello(String name) {
        return "hello--8081--"+name;
    }
}

在src/main/resources下创建applicationContext-service.xml

<?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:p="http://www.springframework.org/schema/p"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
       xmlns:mvc="http://www.springframework.org/schema/mvc"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
		http://www.springframework.org/schema/beans/spring-beans.xsd
         http://www.springframework.org/schema/mvc
         http://www.springframework.org/schema/mvc/spring-mvc.xsd
         http://code.alibabatech.com/schema/dubbo
         http://code.alibabatech.com/schema/dubbo/dubbo.xsd
         http://www.springframework.org/schema/context
         http://www.springframework.org/schema/context/spring-context.xsd">
    <!-- 当前应用名称，用于注册中心计算应用间依赖关系，注意：消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbodemo_provider"/>
    <!--指定注册中心地址-->
    <dubbo:registry address="127.0.0.1:2181" protocol="zookeeper"/>
<!--    <dubbo:registry address="127.0.0.1:2181,127.0.0.1:2182,127.0.0.1:2183" protocol="zookeeper"/>-->
    <!-- 注册协议和port端口 默认是20880 -->
    <!-- 我在2181这个注册中心发布两个提供方 -->
    <dubbo:protocol name="dubbo" port="20881"/>
    <!--    <dubbo:protocol name="dubbo" port="20882"/>-->
    <!--指定要发布成服务的包 加入@Service注解的类会被发布为服务-->
    <dubbo:annotation package="cn.dubbo.service.impl"/>
</beans>

启动服务：tomcat7:run启动，查看发布成功：

4.5 服务消费方开发

创建maven工程：dubbodemo_consumer（打包方式为war），并配置pom.xml文件（将端口号改了即可，其他的与服务提供方相同）：

  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.tomcat.maven</groupId>
        <artifactId>tomcat7-maven-plugin</artifactId>
        <version>2.2</version>
        <configuration>
          <!-- 指定端口 -->
          <port>2011</port>
          <!-- 请求路径 -->
          <path>/</path>
        </configuration>
      </plugin>
    </plugins>
  </build>

配置web.xml文件：

<!DOCTYPE web-app PUBLIC
        "-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN"
        "http://java.sun.com/dtd/web-app_2_3.dtd" >
<web-app>
  <display-name>Archetype Created Web Application</display-name>
  <servlet>
    <servlet-name>springmvc</servlet-name>
    <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
    <!-- 指定加载的配置文件 ，通过参数contextConfigLocation加载 -->
    <init-param>
      <param-name>contextConfigLocation</param-name>
      <param-value>classpath:applicationContext-web.xml</param-value>
    </init-param>
    <load-on-startup>1</load-on-startup>
  </servlet>
  <servlet-mapping>
    <servlet-name>springmvc</servlet-name>
    <url-pattern>*.do</url-pattern>
  </servlet-mapping>
</web-app>

将服务提供者工程中的HelloService接口复制到当前工程

编写Controller

package cn.dubbo.controller;
import cn.dubbo.service.HelloService;
import com.alibaba.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Controller分布式RPC服务调用框架选型：使用Dubbo实现分布式服务调用
 DUBBO分布式RPC远程调用思想
 [dubbo 源码之 ]2. 服务消费方如何启动服务
 Dubbo
 基于Dubbo框架构建分布式服务 
 基于Dubbo框架构建分布式服务