第一个dubbo程序

时间：2023-11-24 15:49:56

Dubbo是一个高性能服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案，使得应用可通过高性能RPC实现服务的输出和输入功能，和Spring框架可以无缝集成。

作为一个分布式服务框架，以及SOA治理方案，Dubbo其功能主要包括：高性能NIO通讯及多协议集成，服务动态寻址与路由，软负载均衡与容错，依赖分析与服务降级等。Dubbo最大的特点是按照分层的方式来架构，使用这种方式可以使各个层之间解耦合（或者最大限度地松耦合）。从服务模型的角度来看，Dubbo采用的是一种非常简单的模型，要么是提供方提供服务，要么是消费方消费服务，所以基于这一点可以抽象出服务提供方（Provider）和服务消费方（Consumer）两个角色。

Dubbo包含远程通讯、集群容错和自动发现三个核心部分。提供透明化的远程方法调用，实现像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。同时具备软负载均衡及容错机制，可在内网替代F5等硬件负载均衡器，降低成本，减少单点。可以实现服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。

下图来自Dubbo官网，描述了服务注册中心、服务提供方、服务消费方、服务监控中心之间的调用关系，具体如下图所示：

第一个dubbo程序

今天的第一个dubbo程序主要就是实现Consumer对Provider的调用
一、Provider(服务提供方)步骤

1.pom.xml如下

<!-- 这里是配置的编译JDK版本和编码方式 -->

<properties>

    <maven.compiler.source>1.8</maven.compiler.source>

    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

    <maven.compiler.target>1.8</maven.compiler.target>

</properties>

<dependencies>

    <!-- spring引入 -->

    <dependency>

        <groupId>org.springframework</groupId>

        <artifactId>spring-core</artifactId>

        <version>4.0.2.RELEASE</version>

    </dependency>

    <dependency>

        <groupId>org.springframework</groupId>

        <artifactId>spring-context</artifactId>

        <version>4.0.2.RELEASE</version>

    </dependency>

    <!-- zookeeper客户端 -->

    <dependency>

        <groupId>com.101tec</groupId>

        <artifactId>zkclient</artifactId>

        <version>0.3</version>

    </dependency>

    <!-- zookeeper核心包 -->

    <dependency>

        <groupId>org.apache.zookeeper</groupId>

        <artifactId>zookeeper</artifactId>

        <version>3.4.5</version>

    </dependency>

    <!-- dubbo核心包引入 -->

    <dependency>

        <groupId>com.alibaba</groupId>

        <artifactId>dubbo</artifactId>

        <version>2.5.7</version>

        <scope>compile</scope>

        <exclusions>

            <exclusion>

                <artifactId>spring</artifactId>

                <groupId>org.springframework</groupId>

            </exclusion>

        </exclusions>

    </dependency>

</dependencies>

2.dubbo.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:context="http://www.springframework.org/schema/context" 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://www.springframework.org/schema/context

                        http://www.springframework.org/schema/context/spring-context-3.1.xsd

     http://code.alibabatech.com/schema/dubbo

     http://code.alibabatech.com/schema/dubbo/dubbo.xsd">

    <context:component-scan base-package="cn.duanjt" />

    <!-- 提供方应用信息，用于计算依赖关系 -->

    <dubbo:application name="storeServer" />

    <!-- 使用zookeeper注册中心暴露服务地址 -->

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

    <!-- 用dubbo协议在20880端口暴露服务 -->

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

    <dubbo:protocol name="rmi" port="21880" />

    <!--和本地bean一样实现服务 -->

    <bean id="vipUserService" class="cn.duanjt.service.impl.VipUserService" />

    <dubbo:service interface="cn.duanjt.service.UserService" ref="vipUserService" protocol="dubbo" />

</beans>

说明：

  • 我们需要在包cn.duanjt(可以是子包下面)下面创建一个接口UserService
  • 我们需要在包cn.duanjt(可以是子包下面)下面创建一个接口UserService的实现类VipUserService
  • 如上的xml配置就是根据接口和实现类暴露接口给zookeeper
  • protocol表示协议方式，可以是dubbo、rmi等。因为dubbo是支持多协议的

3.主方法代码如下：

public class SpringServer {

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

        ClassPathXmlApplicationContext ac=new ClassPathXmlApplicationContext("classpath:dubbo.xml");

        ac.start();

        System.out.println("服务端启动完成");

        System.in.read();

    }

}

二、Consumer(服务消费方)步骤

其实消费方也是可以使用jar包的方式调用，但是为了实现不同的方式，消费方我们使用spring-mvc的方式进行实现。

1.首先搭建一个普通的spring-mvc程序，不会的可以参考spring-mvc

2.pom.xml如下：

<properties>

    <maven.compiler.source>1.8</maven.compiler.source>

    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

    <maven.compiler.target>1.8</maven.compiler.target>

</properties>

<dependencies>

    <!-- servlet的引用 -->

    <dependency>

        <groupId>javax.servlet</groupId>

        <artifactId>javax.servlet-api</artifactId>

        <version>3.1.0</version>

    </dependency>

    <!-- spring引用 -->

    <dependency>

        <groupId>org.springframework</groupId>

        <artifactId>spring-core</artifactId>

        <version>4.0.2.RELEASE</version>

    </dependency>

    <dependency>

        <groupId>org.springframework</groupId>

        <artifactId>spring-webmvc</artifactId>

        <version>4.0.2.RELEASE</version>

    </dependency>

    <!-- zkclient引用 -->

    <dependency>

        <groupId>com.101tec</groupId>

        <artifactId>zkclient</artifactId>

        <version>0.3</version>

    </dependency>

    <!-- zookeeper核心包的引用 -->

    <dependency>

        <groupId>org.apache.zookeeper</groupId>

        <artifactId>zookeeper</artifactId>

        <version>3.4.5</version>

    </dependency>

    <!-- dubbo核心包的引用 -->

    <dependency>

        <groupId>com.alibaba</groupId>

        <artifactId>dubbo</artifactId>

        <version>2.5.7</version>

        <scope>compile</scope>

        <exclusions>

            <exclusion>

                <artifactId>spring</artifactId>

                <groupId>org.springframework</groupId>

            </exclusion>

        </exclusions>

    </dependency>

</dependencies>

3.在springmvc的配置文件(spring-mvc.xml)中引入dubbo配置

第一个dubbo程序

4.dubbo.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: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">

    <!-- 就是注册到zookeeper的名字 -->

    <dubbo:application name="store_client"></dubbo:application>

    <!-- zookeeper地址 -->

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

    <dubbo:consumer check="false" />

    <!-- 从zookeeper引用 -->

    <dubbo:reference id="userService" interface="cn.duanjt.service.UserService"></dubbo:reference>

</beans>

说明：

  • 需要创建一个接口UserService。该接口和服务方的接口完全一致。

5.controller的代码如下：

@Controller

public class UserController {

    @Autowired

    UserService service;

    @RequestMapping("/index")

    public String index(HttpServletRequest request, HttpServletResponse response) {

        String res = service.getDetail("china");//远程rpc调用

        request.setAttribute("detail", res);//将结果设置到detail中

        return "index";

    }

}

6.前端jsp页面（index.jsp）如下:

<%@ page language="java" contentType="text/html; charset=utf-8" pageEncoding="utf-8"%>

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">

<html>

    <head>

        <meta http-equiv="Content-Type" content="text/html; charset=utf-8">

        <title>首页</title>

    </head>

    <body>

        你好，接收到的数据是： ${detail }

    </body>

</html>

前端请求的地址是：http://localhost:8080/index

最后附一张图：

第一个dubbo程序

相关文章