`
weigang.gao
  • 浏览: 490943 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

dubbo helloWorld

 
阅读更多

       互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行，Dubbo是一个分布式服务框架，在这种情况下诞生的。现在核心业务抽取出来，作为独立的服务，使前端应用能更快速和稳定的响应。

第一：Dubbo的简介

节点角色说明：

Provider: 暴露服务的服务提供方。

Consumer: 调用远程服务的服务消费方。

Registry: 服务注册与发现的注册中心。

Monitor: 统计服务的调用次调和调用时间的监控中心。

Container: 服务运行容器。

 

调用关系说明：

0. 服务容器负责启动，加载，运行服务提供者。

1. 服务提供者在启动时，向注册中心注册自己提供的服务。

2. 服务消费者在启动时，向注册中心订阅自己所需的服务。

3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。

4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。

5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。

 

 Dubbo提供了很多协议，Dubbo协议、RMI协议、Hessian协议，我们查看Dubbo源代码，有各种协议的实现，如图所示

上面是参考了Dubbo官方网介绍，接下来我们来介绍SpringMVC、Dubbo、Zookeeper整合使用

第二：Dubbo与Zookeeper,SpringMVC整合使用

①在Linux上安装Zookeeper

       Zookeeper作为Dubbo服务的注册中心，Dubbo原先基于数据库的注册中心，没采用Zookeeper，Zookeeper是一个分布式的服务框架，是树型的目录服务的数据存储，能做到集群管理数据 ，这里能很好的作为Dubbo服务的注册中心，Dubbo能与Zookeeper做到集群部署，当提供者出现断电等异常停机时，Zookeeper注册中心能自动删除提供者信息，当提供者重启时，能自动恢复注册数据，以及订阅请求。我们先在linux上安装Zookeeper，我们安装集群：http://weigang-gao.iteye.com/admin/blogs/2353314

 

②配置dubbo-admin的管理页面，方便我们管理页面

下载dubbo源码：https://github.com/alibaba/dubbo 



1.将源码导入eclipse,目录结构如下

 

2.更新dubbo-parent

 

3.根据eclipse的提示修改错误

 

4.修改dobbo-admin的配置文件dubbo.properties


 

5.打包dubbo-admin，可能会报如下错误(下载opensesame即可，见附件)


 

6.将打包好的dubbo-admin拷贝到tomcat的webapps目录下面


 

7.启动tomcat，并查看日志

 

8.在浏览器中访问：http://10.224.102.101:8080/dubbo-admin ，用户名及密码：root/root


 
 

第三：SpringMVC与Dubbo的整合，这里使用的是Maven的项目管理

我们先开发服务端，项目目录结构如图所示：

配置pom.xml文件

<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/maven-v4_0_0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<groupId>com.alibaba.dubbo</groupId>
	<artifactId>dubbo-provider-demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<packaging>war</packaging>
	<name>dubbo-provider-demo</name>
	<description>test</description>
	<properties>
		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
		<spring.version>3.1.0.RELEASE</spring.version>
		<jetty_version>6.1.25</jetty_version>
	</properties>

	<dependencies>
		<!-- <dependency> <groupId>com.alibaba.rocketmq</groupId> <artifactId>rocketmq-all</artifactId> 
			<version>3.0.4-open</version> <type>pom</type> </dependency> <dependency> 
			<groupId>com.alibaba.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> 
			<version>3.0.4-open</version> </dependency> <dependency> <groupId>com.alibaba.rocketmq</groupId> 
			<artifactId>rocketmq-common</artifactId> <version>3.0.4-open</version> </dependency> -->
		<dependency>
			<groupId>commons-httpclient</groupId>
			<artifactId>commons-httpclient</artifactId>
			<version>3.1</version>
			<scope>compile</scope>
		</dependency>
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpclient</artifactId>
			<version>4.2.3</version>
			<scope>compile</scope>
		</dependency>
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpcore</artifactId>
			<version>4.2.3</version>
			<scope>compile</scope>
		</dependency>
		<dependency>
			<groupId>org.apache.httpcomponents</groupId>
			<artifactId>httpmime</artifactId>
			<version>4.2.3</version>
			<scope>compile</scope>
		</dependency>
		<dependency>
			<groupId>ch.qos.logback</groupId>
			<artifactId>logback-classic</artifactId>
			<version>1.1.1</version>
		</dependency>
		<dependency>
			<groupId>ch.qos.logback</groupId>
			<artifactId>logback-core</artifactId>
			<version>1.1.1</version>
		</dependency>
		<dependency>
			<groupId>junit</groupId>
			<artifactId>junit</artifactId>
			<version>4.10</version>
			<scope>test</scope>
		</dependency>
		<dependency>
			<groupId>org.swinglabs</groupId>
			<artifactId>swingx</artifactId>
			<version>1.6.1</version>
		</dependency>
		<!--Redis -->
		<dependency>
			<groupId>redis.clients</groupId>
			<artifactId>jedis</artifactId>
			<version>2.4.2</version>
			<type>jar</type>
			<scope>compile</scope>
		</dependency>
		<!-- spring -->
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-webmvc</artifactId>
			<version>${spring.version}</version>
			<exclusions>
				<exclusion>
					<groupId>commons-logging</groupId>
					<artifactId>commons-logging</artifactId>
				</exclusion>
			</exclusions>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-web</artifactId>
			<version>${spring.version}</version>
			<exclusions>
				<exclusion>
					<groupId>commons-logging</groupId>
					<artifactId>commons-logging</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-test</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-expression</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-tx</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-core</artifactId>
			<version>${spring.version}</version>
		</dependency>

		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-context</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<dependency>
			<groupId>org.springframework</groupId>
			<artifactId>spring-jdbc</artifactId>
			<version>${spring.version}</version>
		</dependency>
		<!-- 定时器 -->
		<dependency>
			<groupId>org.quartz-scheduler</groupId>
			<artifactId>quartz</artifactId>
			<version>1.7.2</version>
		</dependency>
		<!-- dubbo -->
		<dependency>
			<groupId>com.alibaba</groupId>
			<artifactId>dubbo</artifactId>
			<version>2.4.11</version>
		</dependency>
		<dependency>
			<groupId>org.apache.zookeeper</groupId>
			<artifactId>zookeeper</artifactId>
			<version>3.3.6</version>
			<exclusions>
				<exclusion>
					<groupId>log4j</groupId>
					<artifactId>log4j</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<dependency>
			<groupId>log4j</groupId>
			<artifactId>log4j</artifactId>
			<version>1.2.16</version>
		</dependency>
		<!-- spring mvc 返回 json使用 -->
		<dependency>
			<groupId>org.codehaus.jackson</groupId>
			<artifactId>jackson-core-asl</artifactId>
			<version>1.8.4</version>
		</dependency>
		<dependency>
			<groupId>org.codehaus.jackson</groupId>
			<artifactId>jackson-mapper-asl</artifactId>
			<version>1.8.4</version>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>servlet-api</artifactId>
			<version>2.5</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>javax.servlet</groupId>
			<artifactId>jsp-api</artifactId>
			<version>2.0</version>
			<scope>provided</scope>
		</dependency>
		<dependency>
			<groupId>com.github.sgroschupf</groupId>
			<artifactId>zkclient</artifactId>
			<version>0.1</version>
		</dependency>
	</dependencies>
	<build>
		<plugins>
			<plugin>
				<groupId>org.apache.maven.plugins</groupId>
				<artifactId>maven-surefire-plugin</artifactId>
				<version>2.12.4</version>
				<configuration>
					<skipTests>true</skipTests>
				</configuration>
			</plugin>
			<plugin>
				<groupId>org.mortbay.jetty</groupId>
				<artifactId>maven-jetty-plugin</artifactId>
				<version>6.1.25</version>
				<configuration>
					<connectors>
						<connector implementation="org.mortbay.jetty.nio.SelectChannelConnector">
							<port>8090</port>
							<maxIdleTime>60000</maxIdleTime>
						</connector>
					</connectors>
				</configuration>
			</plugin>
		</plugins>
		<finalName>dubbo-provider-demo</finalName>
	</build>

</project>

 

①实体类MsgInfo定义

package com.alibaba.dubbo.model;

import java.io.Serializable;
import java.util.List;

public class MsgInfo implements Serializable {

	private static final long serialVersionUID = -2814022769568306965L;

	int id;
	String name;
	List<String> msgs;

	public int getId() {
		return id;
	}

	public void setId(int id) {
		this.id = id;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public List<String> getMsgs() {
		return msgs;
	}

	public void setMsgs(List<String> msgs) {
		this.msgs = msgs;
	}

}

 

②服务接口定义IDemoService:

package com.alibaba.dubbo.service;

import com.alibaba.dubbo.model.MsgInfo;

public interface IDemoService {
	 public void sayHello();
	    
	    public String returnHello();
	    
	    public MsgInfo returnMsgInfo(MsgInfo info);
}

③服务接口实现DemoService

package com.alibaba.dubbo.service.impl;

import com.alibaba.dubbo.model.MsgInfo;
import com.alibaba.dubbo.service.IDemoService;

public class DemoService implements IDemoService{
	
	public void sayHello() {
		System.out.println("hello world!");
	}

	public String returnHello() {
		return "hello world!";
	}

	public MsgInfo returnMsgInfo(MsgInfo info) {
		info.getMsgs().add("处理完毕");
		return info;
	}
}

 

⑤配置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="hello-world-app" />
	
	<!-- zookeeper注册中心 -->
	<dubbo:registry protocol="zookeeper" address="10.224.102.101:2181,10.224.102.102:2181,10.224.102.103:2181" />
	<!-- 使用multicast广播注册中心暴露服务地址 -->
	<!-- <dubbo:registry address="multicast://10.57.41.19:1234" /> -->
	<dubbo:protocol name="dubbo" port="20880" />
	<dubbo:service interface="com.alibaba.dubbo.service.IDemoService"
		ref="demoService" />       <!-- 和本地bean一样实现服务 -->
	<bean id="demoService" class="com.alibaba.dubbo.service.impl.DemoService" />
</beans>

说明：

   dubbo:registry 标签一些属性的说明：

      1）register是否向此注册中心注册服务，如果设为false，将只订阅，不注册。

      2）check注册中心不存在时，是否报错。

      3）subscribe是否向此注册中心订阅服务，如果设为false，将只注册，不订阅。

      4）timeout注册中心请求超时时间(毫秒)。

      5）address可以Zookeeper集群配置，地址可以多个以逗号隔开等。

  dubbo:service标签的一些属性说明：

     1）interface服务接口的路径

     2）ref引用对应的实现类的Bean的ID

     3）registry向指定注册中心注册，在多个注册中心时使用，值为<dubbo:registry>的id属性，多个注册中心ID用逗号分隔，如果不想将该服务注册到任何registry，可将值设为N/A

     4）register 默认true ，该协议的服务是否注册到注册中心。

 

⑥打包dubbo-provider-demo并发布到tomcat服务器上，然后我们在Dubbo管理页面上显示，已经暴露的服务，但显示还没有消费者，因为我们还没实现消费者服务，如图所示：


 第二：再开发服务调用者，Maven项目的目录结构如下：


 MsgInfo，IDemoService，pom.xml文件与服务提供方相同，在此省略

①配置dubbo-consumer.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="consumer-of-helloworld" />
	<!-- zookeeper注册中心 -->
	<dubbo:registry  protocol="zookeeper" address="10.224.102.101:2181,10.224.102.102:2181,10.224.102.103:2181" />  
	<!-- 使用multicast广播注册中心暴露的服务地址 -->
	<!--<dubbo:registry address="multicast://10.57.41.19:1234" /> -->
	 <!-- 生成远程服务代理，可以和本地bean一样使用demoService -->
	<dubbo:reference id="demoService" interface="com.alibaba.dubbo.service.IDemoService" />
</beans>

 

②编写测试类ConsumerTest

package com.alibaba.dubbo.service;

import java.util.ArrayList;
import java.util.List;

import org.I0Itec.zkclient.ZkClient;
import org.I0Itec.zkclient.serialize.SerializableSerializer;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.alibaba.dubbo.model.MsgInfo;


public class ConsumerTest {
	
	public static void main(String[] args) {
		ConsumerTest test = new ConsumerTest();
		test.start();
	}
	
	public void start(){
		System.out.println("consumerTest start...");
		String configLocation="META-INF/spring/dubbo-consumer.xml";
		ApplicationContext context =new  ClassPathXmlApplicationContext(configLocation);
		IDemoService ds=(IDemoService) context.getBean("demoService");
		String [] names=context.getBeanDefinitionNames();
		System.out.print("Beans:");
		for (String string : names) {
			System.out.print(string);
			System.out.print(",");
		}
		System.out.println();
		
		MsgInfo info =new MsgInfo();
		info.setId(1);
		info.setName("ruisheh");
		List<String> msgs=new ArrayList<String>();
		msgs.add("I");
		msgs.add("am");
		msgs.add("test");
		info.setMsgs(msgs);
		
		System.out.println(ds.returnMsgInfo(info).getMsgs());
	}
}

 

 

③测试结果：


注意：在本地测试的时候需要配置hosts文件，否者会报zookeeper连接超时，如下



本人机器上host文件配置


 

 

在dubbo管理页面查看调用者信息


 

 

 

参考：http://blog.csdn.net/congcong68/article/details/41113239

  • 大小: 67.9 KB
  • 大小: 4.4 KB
  • 大小: 80.5 KB
  • 大小: 8.1 KB
  • 大小: 28.3 KB
  • 大小: 6.9 KB
  • 大小: 16.5 KB
  • 大小: 38.9 KB
  • 大小: 50.9 KB
  • 大小: 17.2 KB
  • 大小: 62.8 KB
  • 大小: 54.5 KB
  • 大小: 2 KB
  • 大小: 50.8 KB
分享到：
| SSH免密码登录
评论
发表评论

您还没有登录,请您登录后再发表评论

相关推荐

    zookeeper + dubbo helloworld

    本示例“Zookeeper + Dubbo HelloWorld”旨在帮助初学者理解如何将这两个组件结合使用，以构建一个简单的服务消费和服务提供者示例。下面我们将深入探讨Zookeeper和Dubbo的核心概念以及它们在该示例中的作用。 **...

    springMVC+spring+dubbo hello world测试项目

    在这个"springMVC+spring+dubbo hello world测试项目"中，我们可以期待看到以下主要目录和文件： 1. `src/main/java`：包含项目的源代码，可能有如com.example.demo包，下设Service、Controller和配置类等。 2. `...

    dubbo 入门案例 helloworld

    【标题】"Dubbo入门案例HelloWorld"是一个基础的学习教程，旨在帮助初学者理解并实践Dubbo框架的基本用法。Dubbo是阿里巴巴开源的一款高性能、轻量级的Java RPC（远程过程调用）框架，它提供了服务治理、负载均衡、...

    dubbo得helloworld

    【标题】"Dubbo HelloWorld 实践教程" 在IT行业中，Dubbo是一款由阿里巴巴开源的高性能、轻量级的服务治理框架，主要用于实现分布式服务的开发、治理和服务发现。本教程将带你走进Dubbo的世界，通过一个简单的...

    Dubbo搭建HelloWorld-创建服务提供者与消费者示例代码

    在本教程中，我们将深入探讨如何使用Apache Dubbo构建一个简单的"Hello, World"应用程序，该程序包括服务提供者和服务消费者。Dubbo是一款高性能、轻量级的Java RPC框架，它能够帮助开发者实现分布式服务之间的通信...

    dubbo之HelloWorld

    【Dubbo HelloWorld 实践详解】 在分布式系统开发中，Dubbo 是一款广泛使用的高性能 Java RPC 框架，它能够帮助开发者构建微服务架构，实现服务间的高效通信。本篇文章将详细讲解如何通过 Dubbo 和 Zookeeper 实现...

    Dubbo新手入门实例HelloWorld(zookeeper)源码

    在本实例中，我们将探讨如何使用Dubbo和Zookeeper进行一个简单的"HelloWorld"入门实践。 首先，我们需要理解Dubbo的核心概念。Dubbo提供了服务提供者（Provider）、服务消费者（Consumer）、注册中心（Registry）和...

    Dubbo入门之HelloWorld

    本文将基于"Dubbo入门之HelloWorld"的主题，深入探讨如何从零开始学习并实践Dubbo的基本用法。 首先，我们需要了解什么是RPC（Remote Procedure Call）。RPC是一种使程序可以调用另一个系统中的函数或方法的技术，...

    Dubbo入门之hello world（简单测试版和使用注解加强版）

    用maven构建项目使用spring和multicast广播注册中心方式实现Dubbo入门之hello world（用maven构建项目使用spring和multicast广播注册中心方式实现Dubbo入门之hello world（简单测试版）文档说明以及源码

    配置 dubbo 的Hello World

    在本教程中，我们将深入探讨如何配置Dubbo的“Hello World”示例，这是一个非常基础但重要的步骤，用于快速理解Dubbo框架的工作原理。Dubbo是阿里巴巴开源的一个高性能、轻量级的服务治理框架，它专注于服务调用、...

    dubbo helloword demo

    【Dubbo HelloWorld Demo详解】 在IT行业中，框架的学习与应用是开发者成长的必经之路，Dubbo作为阿里巴巴开源的一款高性能、轻量级的Java RPC框架，对于服务治理有着卓越的表现。"Dubbo HelloWorld Demo"是入门...

    Dubbo_Demo_HelloWorld

    【Dubbo_Demo_HelloWorld】是一个典型的Dubbo学习示例，它涵盖了服务提供者（Service Provider）、服务消费者（Service Consumer）以及Dubbo的核心API使用。这个Demo旨在帮助初学者理解Dubbo的基本工作原理和核心...

    Dubbo Demo

    Dubbo Hello World Demo！！ &lt;groupId&gt;com.alibaba&lt;/groupId&gt; &lt;artifactId&gt;dubbo &lt;version&gt;2.4.10&lt;/version&gt;

    dubbo源码解析2

    一个典型的Dubbo HelloWorld例子通常包括服务提供者和服务消费者两个部分，通过简单的示例程序演示了如何注册服务、发布服务和调用服务。 #### 五、源文件概述 Dubbo的源代码主要由以下几个部分组成： 1. **core*...

    Dubbo新手入门实例HelloWorld(zookeeper)源码低分版

    Dubbo新手入门实例“HelloWorld”是初学者学习分布式服务框架Dubbo的典型起点。这个实例结合了Zookeeper作为注册中心，帮助理解Dubbo的基本工作原理。以下将详细讲解涉及的知识点。 首先，Dubbo是一个高性能、轻量...

Magicbox
Global site tag (gtag.js) - Google Analytics