dubbo本地搭建实例

项目文件下载地址：http://download.csdn.net/detail/aqsunkai/9552711

概述

Dubbo是一个分布式服务框架，致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。

其核心部分包含

  • 远程通讯: 提供对多种基于长连接的NIO框架抽象封装，包括多种线程模型，序列化，以及“请求-响应”模式的信息交换方式。
  • 集群容错: 提供基于接口方法的透明远程过程调用，包括多协议支持，以及软负载均衡，失败容错，地址路由，动态配置等集群支持。
  • 自动发现: 基于注册中心目录服务，使服务消费方能动态的查找服务提供方，使地址透明，使服务提供方可以平滑增加或减少机器。

Dubbo能做什么

透明化的远程方法调用，就像调用本地方法一样调用远程方法，只需简单配置，没有任何API侵入。

软负载均衡及容错机制，可在内网替代F5等硬件负载均衡器，降低成本，减少单点。

服务自动注册与发现，不再需要写死服务提供方地址，注册中心基于接口名查询服务提供者的IP地址，并且能够平滑添加或删除服务提供者。

主要核心部件

Remoting: 网络通信框架，实现了sync-over-async 和 request-response 消息机制.

RPC: 一个远程过程调用的抽象，支持负载均衡、容灾和集群功能

Registry: 服务目录框架用于服务的注册和服务事件发布和订阅。

Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。

Dubbo采用全Spring配置方式，透明化接入应用，对应用没有任何API侵入，只需用Spring加载Dubbo的配置即可，Dubbo基于Spring的Schema扩展进行加载。

实例

搭建maven web项目

不会搭建maven项目的可以参考我的博客：http://blog.csdn.net/aqsunkai/article/details/51286373

本例我搭建了两个项目：dubbo-provider和dubbo-customer

修改配置文件

dubbo-provider项目

在pom.xml文件中增加dubbo、zookeeper、zkclient的jar包：

    <!-- http://mvnrepository.com/artifact/com.alibaba/dubbo -->
 <dependency>
	    <groupId>com.alibaba</groupId>
	    <artifactId>dubbo</artifactId>
	    <version>2.5.3</version>
 </dependency>
    <!-- http://mvnrepository.com/artifact/com.101tec/zkclient -->
	<dependency>
	    <groupId>com.101tec</groupId>
	    <artifactId>zkclient</artifactId>
	    <version>0.8</version>
	</dependency>
    <!-- http://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper -->
	<dependency>
	    <groupId>org.apache.zookeeper</groupId>
	    <artifactId>zookeeper</artifactId>
	    <version>3.4.8</version>
	    <!-- <type>pom</type> -->
	</dependency>

因为要作为web项目启动，web.xml文件中需要增加：

必须有ContextLoaderListener监听器，applicationContext.xml才会成功加载

  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:applicationContext.xml</param-value>
  </context-param>

下面是DemoService和DemoServiceImpl的内容

public interface DemoService {
   String getName(String firstName,String lastName);
}
public class DemoServiceImpl implements DemoService{
   @Override
   public String getName(String firstName, String lastName) {
      return "hello， "+firstName+" " +lastName;
   }
}

applicationContext.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
        ">

	<!-- 具体的实现bean -->
	<bean id="demoService" class="com.cn.provider.impl.DemoServiceImpl" />

	<!-- 提供方应用信息，用于计算依赖关系 -->
	<dubbo:application name="provider" />

	<!-- 使用multicast广播注册中心暴露服务地址 <dubbo:registry address="multicast://127.0.0.1:1234" /> -->

	<!-- 使用zookeeper注册中心暴露服务地址 -->
	<dubbo:registry address="zookeeper://127.0.0.1:2181"/>

	<!-- 用dubbo协议在20880端口暴露服务 -->
	<dubbo:protocol name="dubbo" port="20880" />

	<!-- 声明需要暴露的服务接口 -->
	<dubbo:service interface="com.cn.provider.DemoService"
		ref="demoService"/>
</beans>

该项目作为web项目用tomcat启动的话，已经配置完毕，还可以直接用main方法加载配置文件模拟项目启动，需要多一个java类

Provider中的内容为：

public class Provider {
	public static void main(String[] args) throws Exception {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
				new String[] { "applicationContext.xml" });
		context.start();
		System.out.println("dubbo-provider启动");
		System.in.read(); // 为保证服务一直开着，利用输入流的阻塞来模拟
	}
}

dubbo-customer项目

因为dubbo-customer需要引入dubbo-provider项目中DemoService的jar包，pom.xml文件内容要加上：

   <!-- http://mvnrepository.com/artifact/com.alibaba/dubbo -->
 <dependency>
	    <groupId>com.alibaba</groupId>
	    <artifactId>dubbo</artifactId>
	    <version>2.5.3</version>
 </dependency>
    <!-- http://mvnrepository.com/artifact/com.101tec/zkclient -->
	<dependency>
	    <groupId>com.101tec</groupId>
	    <artifactId>zkclient</artifactId>
	    <version>0.8</version>
	</dependency>
    <!-- http://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper -->
	<dependency>
	    <groupId>org.apache.zookeeper</groupId>
	    <artifactId>zookeeper</artifactId>
	    <version>3.4.8</version>
	    <!-- <type>pom</type> -->
	</dependency>
 <dependency>
     <groupId>javabuilder</groupId>
     <artifactId>javabuilder</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <scope>system</scope>
     <systemPath>${project.basedir}/src/main/webapp/WEB-INF/lib/dubbo-provider.jar</systemPath>
 </dependency>

记得把dubbo-provider.jar放到项目WEB-INF/lib下，生成jar包的方法可参考我的博客：http://blog.csdn.net/aqsunkai/article/details/51711580

整个项目我想既可以用main方法启动加载配置文件，也可以作为web项目用tomcat启动，在浏览器中看到结果，那么我一定需要在pom.xml中引入spring的jar包吗，答案是no，我只需要写servlet，直接进入doGet方法即可验证，那么就需要修改web.xml

  <listener>
    <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
  </listener>
  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>classpath:applicationContext.xml</param-value>
  </context-param>
  <welcome-file-list>
    <welcome-file>index.jsp</welcome-file>
  </welcome-file-list>
  <servlet>
    <servlet-name>servletDemo</servlet-name>
    <servlet-class>com.cn.customer.Servlet</servlet-class>
  </servlet>
  <servlet-mapping>
    <servlet-name>servletDemo</servlet-name>
    <url-pattern>/index</url-pattern>
  </servlet-mapping>

applicationContext.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="customer" />

	<!-- 使用zookeeper注册中心暴露服务地址 -->
	<!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
	<dubbo:registry address="zookeeper://127.0.0.1:2181"/>

	<!-- 生成远程服务代理，可以像使用本地bean一样使用demoService -->
	<dubbo:reference id="demoService"
		interface="com.cn.provider.DemoService"/>

	<!-- 目的是用ApplicationContext获取bean,与dubbo项目无关 -->
	<bean class="com.cn.customer.AppContext"/>
</beans>

servlet.java文件的内容为：

public class Servlet extends HttpServlet{

     /**
	  *
	  */
	 private static final long serialVersionUID = 1L;
	 //初始化
	 public void init() throws ServletException {
	   System.out.println("我是init()方法！用来进行初始化工作");
	 }
     //处理GET请求
	 public void doGet(HttpServletRequest request, HttpServletResponse response)
	  throws ServletException, IOException {
	   System.out.println("我是doGet()方法！用来处理GET请求");
	   response.setContentType("text/html;charset=utf-8");
	   PrintWriter out = response.getWriter();
	   out.println("<HTML>");
	   out.println("<BODY>");
	   /*
	    * 通过Spring提供的工具类获取ApplicationContext对象
	    */
	   //ServletContext sc = this.getServletContext(); //和下面一行一样，都能获取ServletContext
	   ServletContext sc = request.getSession().getServletContext();
	   //第一种获取bean方法，获取失败时抛出异常
	   ApplicationContext ac1 = WebApplicationContextUtils.getRequiredWebApplicationContext(sc);
	   DemoService demoService1 = (DemoService)ac1.getBean("demoService");
	   String name1 = demoService1.getName("tom", "Edison");
	   out.println(name1);
	   out.println("<br>");
	   //第二种获取bean方法，获取失败时返回null
	   ApplicationContext ac2 = WebApplicationContextUtils.getWebApplicationContext(sc);
	   DemoService demoService2 = (DemoService)ac2.getBean("demoService");
	   String name2 = demoService2.getName("tom", "Edison");
	   out.println(name2);
	   out.println("<br>");
	   //第三种获取bean方法
	   WebApplicationContext wac = (WebApplicationContext)sc.getAttribute(
	   WebApplicationContext.ROOT_WEB_APPLICATION_CONTEXT_ATTRIBUTE);
	   DemoService demoService3 = (DemoService)wac.getBean("demoService");
	   String name3 = demoService3.getName("tom", "Edison");
	   out.println(name3);
	   out.println("<br>");
	   //第四种获取bean方法，实现ApplicationContextAware接口
	   AppContext aContext = new AppContext();
	   DemoService demoService4 = (DemoService)aContext.getBean("demoService");
	   String name4 = demoService4.getName("tom", "Edison");
	   out.println(name4);
	   out.println("</BODY>");
	   out.println("</HTML>");
	  }
	  //处理POST请求
	 public void doPost(HttpServletRequest request, HttpServletResponse response)
	  throws ServletException, IOException {
	   System.out.println("我是doPost()方法！用来处理POST请求");
	   doGet(request, response);
      }
	  //销毁实例
	 public void destroy() {
	   super.destroy();
	   System.out.println("我是destroy()方法！用来进行销毁实例的工作");
	  }
}

上面文件中的获取bean的方法：第一二三种都是直接获取，第四种需要写一个实现ApplicationContextAware接口的类，在java类中获取spring的bean的方法可以参考我的博客：http://blog.csdn.net/aqsunkai/article/details/51700645

public class AppContext implements ApplicationContextAware{

	private static ApplicationContext applicationContext;
	/**
	 * 当继承了ApplicationContextAware类之后，那么程序在调用
	 * getBean(String)的时候会自动调用该方法，不用自己操作
	 */
	@Override
	public void setApplicationContext(
			org.springframework.context.ApplicationContext applicationContext)
			throws BeansException {
		this.applicationContext= applicationContext;
	}

	public Object getBean(String beanName){
		return this.applicationContext.getBean(beanName);
	}
}

提醒一句，别忘了导入dubbo-provider中的DemoService接口的jar包，该项目作为web项目用tomcat启动的话，已经配置完毕，还可以直接用main方法加载配置文件模拟项目启动，需要多一个java类

Customer.java内容为：

public class Customer{
	public static void main(String[] args) throws Exception {
		ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
				new String[] { "applicationContext.xml" });
		context.start();
		DemoService demoService = (DemoService) context.getBean("demoService");
		String name = demoService.getName("tom", "Edison");
		System.out.println(name);
		System.in.read();
	}
}

启动项目

1 启动zookeeper注册中心，不会的可参考我的博客：http://blog.csdn.net/aqsunkai/article/details/51683632

2 启动项目，dubbo-provider和dubbo-customer项目都分别支持main方法和tomcat启动，两两组合启动即可。如果dubbo-customer项目用tomcat启动的话，在浏览器url输入http://localhost:8088/dubbo-customer/index即可看到结果

时间： 2024-10-12 22:50:57

dubbo本地搭建实例的相关文章

DUBBO本地搭建及小案例 （转）

DUBBO的介绍部分我这里就不介绍了,大家可参考官方文档. DUBBO的注册中心安装 DUBBO的注册中心支持好几种,公司用到zookeeper注册中心,所以我这边只说明zookeeper注册中心如何安装. 安装zookeeper注册中心首先得下载zookeeper.大家可到zookeeper的官网http://zookeeper.apache.org/releases.html上去下载. 我下载了zookeeper-3.4.5.tar.gz版本的包.接下来把zookeeper-3.4.5.ta

【2020-03-21】Dubbo本地环境搭建-实现服务注册和消费

前言 本周主题:加班工作.本周内忙于CRUD不能自拔,基本每天都是九点半下班,下周上线,明天还要加班推进进度.今天是休息日,于是重拾起了dubbo,打算近期深入了解一下其使用和原理.之所以说是重拾,是因为去年自学过一次,但那次主要是针对源码的流程,在实战上欠缺,且对其理解未深入到架构层次,只能说是基本理解.现在的我跟去年比起来,对技术的理解上有了一些提升,经验也更丰富,故本次目标是做深入研究,且看能从中吸收多少要义. 今天先记录一下dubbo本地服务的简易搭建流程. 一.环境准备 本次搭建用zo

dubbo的使用实例

一.项目结构 用 maven 多模块的构建方式,在 spring-dubbo 下构建三个子模块: dubbo-common:公共模块,用于存放公共的接口和 bean,被 dubbo-provider 和 dubbo-provider 所引用: dubbo-provider :服务的提供者,提供商品的查询服务: dubbo-provider :是服务的消费者,调用 provider 提供的查询服务. 另外,本项目 Dubbo 的搭建采用 ZooKeeper 作为注册中心. 二.项目依赖 在父工程的

SSH框架总结（框架分析+环境搭建+实例源代码下载）

首先,SSH不是一个框架,而是多个框架(struts+spring+hibernate)的集成,是眼下较流行的一种Web应用程序开源集成框架,用于构建灵活.易于扩展的多层Web应用程序. 集成SSH框架的系统从职责上分为四层:表示层.业务逻辑层.数据持久层和域模块层(实体层). Struts作为系统的总体基础架构,负责MVC的分离,在Struts框架的模型部分,控制业务跳转,利用Hibernate框架对持久层提供支持.Spring一方面作为一个轻量级的IoC容器,负责查找.定位.创建和管理对象及

使用APMServ本地搭建多个网站

October 27, 2014 使用APMServ本地搭建多个网站教程 把我写好的代码直接粘贴到 httpd.conf 文件的末尾.然后保存就可以了.代码如下: <VirtualHost *:80> ServerAdmin * DocumentRoot "E:/APMServ5.2.6/www/htdocs/haochang" ServerName www.web.com </VirtualHost> <VirtualHost *:80> Serv

Nginx网站服务器搭建实例

Nginx是一款开源的高性能HTTP服务器和返向代理服务器. 下载.编译.安装模块: [[email protected] nginx-1.4.0]#wget http://nginx.org/download/nginx-1.4.0.tar.gz [[email protected] nginx-1.4.0]#tar -xzf nginx-1.4.0.tar.gz -C /usr/src/ [[email protected] nginx-1.4.0]#yum -y install gcc p

elasticsearch集群搭建实例

下个月又开始搞搜索了,几个月没动这块还好没有落下. 晚上在自己虚拟机上搭建了一个简易搜索集群,分享一下. 操作系统环境: Red Hat 4.8.2-16 elasticsearch : elasticsearch-1.4.1 集群搭建方式: 一台虚拟机上2个节点. 集群存放路径:/export/search/elasticsearch-cluster 必备环境:  java运行环境 集群搭建实例展示: 1. 解压tar包,创建集群节点 #进入到集群路径 [[email protected] e

【转】Spring+Mybatis+SpringMVC+Maven+MySql搭建实例

林炳文Evankaka原创作品.转载请注明出处http://blog.csdn.net/evankaka 摘要:本文主要讲了如何使用Maven来搭建Spring+Mybatis+SpringMVC+MySql的搭建实例,文章写得很详细,有代码有图片,最后也带有运行的效果. 本文工程免费下载 一.准备工作 1. 首先创建一个表: CREATE TABLE `t_user` ( `USER_ID` int(11) NOT NULL AUTO_INCREMENT, `USER_NAME` char(3

Spring+Mybatis+Maven+MySql搭建实例

林炳文Evankaka原创作品.转载请注明出处http://blog.csdn.net/evankaka 摘要:本文主要讲了如何使用Maven来搭建Spring+Mybatis+MySql的的搭建实例,文章写得很详细,有代码有图片,最后也带有运行的效果. 一.准备工作 1. 首先创建一个表: CREATE TABLE `t_user` ( `USER_ID` int(11) NOT NULL AUTO_INCREMENT, `USER_NAME` char(30) NOT NULL, `USER