您现在的位置是：首页 > 后台技术 > dubbodubbo

第四章使用dubbo的第一个项目(图文)

第十三双眼睛2021-06-19【dubbo】人已围观

简介点对点的直连项目:消费者直接访问服务提供者，没有注册中心。消费者必须指定服务
提供者的访问地址（url）。

服务提供者

服务提供者开发步骤：
定义服务接口 (该接口需单独打包，在服务提供方和消费方共享)
在服务提供方实现接口（对服务消费方隐藏实现）
用 Spring 配置声明暴露服务
加载 Spring 配置（创建 bean）
项目结构：

新建 web 项目，命名：dubbo-provider
导入 jar

dubbo.jar: Dubbo 框架的实现
javaassist-3.15.0-GA.jar:字节码生成 jar
netty-3.2.5.Final.jar：网络传输
spring-*.jar: Dubbo 是基于 spring 的。配置 bean。
定义表示天气信息的对象 Weather

定义服务的接口（面向接口编程）

定义天气接口的实现类

编写 Spring 配置文件，Spring 作为容器管理对象

<?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="dubbo-provider"/>

<dubbo:service interface="com.xinchen.service.WeatherService"
                protocol="dubbo"
                ref="weatherService"
                registry="N/A"/>


<bean id="weatherService" class="com.xinchen.service.impl.WeatherServiceImpl"></bean>

</beans>

修改 web.xml 文件，web 应用中使用 Spring

<context-param>
   <param-name>contextConfigLocation</param-name>
   <param-value>classpath:dubbo-provider.xml</param-value>
</context-param>

<listener>
   <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>

至此，服务提供者的功能实现完成。

服务消费者
将提供者中的实体类和接口文件导出成一个jar包

服务消费者项目可以是 j2se, j2ee 等项目类型，使用服务。
服务消费者开发步骤：
通过 Spring 配置引用远程服务
加载 Spring 配置，并调用远程服务：(也可以使用 IoC 注入)
项目结构

新建 java project ,命名 dubbo-consumer
导入 jar 服务提供者的jar包中取出webmvc 和web的包
新建配置文件 dubbo-consume.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">


<dubbo:application name="dubbo-consumer"/>

<dubbo:reference id="remoteWeatherService"
                interface="com.xinchen.service.WeatherService"
                url="dubbo://localhost:20880"/>
</beans>

定义测试类访问

package test;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.xinchen.service.WeatherService;

public class A {

   public static void main(String[] args) {
       ApplicationContext context = new ClassPathXmlApplicationContext("dubbo-consumer.xml");
       WeatherService weather = (WeatherService)context.getBean("remoteWeatherService");
       System.out.println(weather.queryWeather("2222"));

   }
}

测试访问远程服务
先启动服务提供者，再执行服务消费者

到此，表明dubbo方式的服务提供者和服务消费者都完成
注入方式使用远程服务对象
新建使用远程服务对象的 Service InvokeService

package test;

import com.xinchen.entity.Weather;
import com.xinchen.service.WeatherService;

public class InvokeService {
   private WeatherService weatherService;
   public void printService(){
       Weather weather = weatherService.queryWeather("111");
       System.out.println(weather);
   }
   public void setWeatherService(WeatherService weatherService) {
       this.weatherService = weatherService;
   }
}

修改 dubbo-consume.xml 声明 ShowWeatherService 对象，注入服务提供者对象

<bean id="invokeService" class="test.InvokeService">
<property name="weatherService" ref="remoteWeatherService"></property>
</bean>

测试运行测试类

package test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class B {
   public static void main(String[] args) {
       ApplicationContext context = new ClassPathXmlApplicationContext("dubbo-consumer.xml");
       InvokeService invokeService = (InvokeService)context.getBean("invokeService");
       invokeService.printService();
   }
}