Dubbo之入门例子HelloWorld

￡神魔★判官ぃ 2022-07-11 01:59 217阅读 0赞

1、项目的目录结构

![20170116144135937][]

2、关于Zookeeper的安装

关于Zookeeper的安装，详情见前面的博客  [http://blog.csdn.net/zbw18297786698/article/details/53011449][http_blog.csdn.net_zbw18297786698_article_details_53011449]

3、关于项目的jar的版本，统一在mydubbo-parent中管理

1.在引用dubbo时，应该排除其对Spring的依赖

<dependency>
    				<groupId>com.alibaba</groupId>
    				<artifactId>dubbo</artifactId>
    				<version>${dubbo.version}</version>
    				<exclusions>
    					<exclusion>
    						<groupId>org.springframework</groupId>
    						<artifactId>spring</artifactId>
    					</exclusion>
    				</exclusions>
    			</dependency>

2.完整的用于统一管理jar版本的pom的配置文件

<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>
    	<groupId>com.baowei.mydubbo</groupId>
    	<artifactId>mydubbo-parent</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>pom</packaging>
    
    
    	
    	<properties>
    		<junit.version>4.10</junit.version>
    		<spring.version>4.1.3.RELEASE</spring.version>
    		<slf4j.version>1.6.4</slf4j.version>
    		<dubbo.version>2.5.3</dubbo.version>
    		<zkclient.version>0.4</zkclient.version>
    	</properties>
    
    	<dependencyManagement>
    		<dependencies>
    			
    			<dependency>
    				<groupId>junit</groupId>
    				<artifactId>junit</artifactId>
    				<version>${junit.version}</version>
    				<scope>test</scope>
    			</dependency>
    			
    			<dependency>
    				<groupId>com.101tec</groupId>
    				<artifactId>zkclient</artifactId>
    				<version>${zkclient.version}</version>
    			</dependency>
    			
    			<dependency>
    				<groupId>com.alibaba</groupId>
    				<artifactId>dubbo</artifactId>
    				<version>${dubbo.version}</version>
    				<exclusions>
    					<exclusion>
    						<groupId>org.springframework</groupId>
    						<artifactId>spring</artifactId>
    					</exclusion>
    				</exclusions>
    			</dependency>
    
    			
    			<dependency>
    				<groupId>org.springframework</groupId>
    				<artifactId>spring-context</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-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-test</artifactId>
    				<version>${spring.version}</version>
    			</dependency>
    
    			
    
    			<dependency>
    				<groupId>org.slf4j</groupId>
    				<artifactId>slf4j-log4j12</artifactId>
    				<version>${slf4j.version}</version>
    			</dependency>
    
    		</dependencies>
    	</dependencyManagement>
    
    	<build>
    		<finalName>${project.artifactId}</finalName>
    		<plugins>
    			
    			<plugin>
    				<groupId>org.apache.maven.plugins</groupId>
    				<artifactId>maven-resources-plugin</artifactId>
    				<version>2.7</version>
    				<configuration>
    					<encoding>UTF-8</encoding>
    				</configuration>
    			</plugin>
    			
    			<plugin>
    				<groupId>org.apache.maven.plugins</groupId>
    				<artifactId>maven-compiler-plugin</artifactId>
    				<version>3.2</version>
    				<configuration>
    					<source>1.7</source>
    					<target>1.7</target>
    					<encoding>UTF-8</encoding>
    				</configuration>
    			</plugin>
    		</plugins>
    
    	</build>
    </project>

4、mydubbo-facade的目录结构

![20170116132836027][]

5、mydubbo-provider

1.对于服务的实现

import org.springframework.stereotype.Component;
    import com.baowei.entity.People;
    import com.baowei.rpc.SpeakInterface;
    
    @Component("speakInterface")
    public class SpeakInterfaceImpl implements SpeakInterface {
    
    	public String speak(People people) {
    		return "dubbo return " + people.getAge();
    	}
    }

2.关于Spring配置文件的放置和Dubbo服务的提供的第一种方式

2.1 Spring配置文件的放置，**放在spring的文件夹下面**

![20170116134216913][]

2.2 Dubbo服务提供的方式，**自己编写的用于调试的服务启动方式**

import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    public class DubboProvider {
    
    	public static void main(String[] args) {
    		try {
    			// 用于加载Spring的配置文件
    			ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
    					"/spring/spring-*.xml");
    			context.start();
    		} catch (Exception exception) {
    			throw new RuntimeException("DubboProvider context start error: "
    					+ exception);
    		}
    		synchronized (DubboProvider.class) {
    			while (true) {
    				try {
    					DubboProvider.class.wait();
    				} catch (InterruptedException e) {
    					throw new RuntimeException("synchronized error: " + e);
    				}
    			}
    
    		}
    
    	}
    }

3.关于Spring配置文件的放置和Dubbo服务的提供的第二种方式

3.1 Spring配置文件的放置，**放在META-INF文件夹下的spring的文件夹下**

![20170116134654154][]

3.2 Dubbo服务提供的方式，**使用Dubbo提供的Main来启动服务**

![20170116135059222][]

4.关于dubbo的配置文件，spring-dubbo-provider.xml

5.关于Spring的配置文件，spring-context.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"
    	xsi:schemaLocation="
              http://www.springframework.org/schema/beans
              http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/context
           http://www.springframework.org/schema/context/spring-context-3.0.xsd">
    
    
    	<context:component-scan base-package="com.baowei.rpc.impl" />
    
    
    </beans>

6、mydubbo-consumer

6.1 配置文件的放置

![20170116140022172][]

6.2 dubbo消费者的配置

6.3 获取Dubbo服务并调用

import org.springframework.context.ApplicationContext;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    import com.baowei.entity.People;
    import com.baowei.rpc.SpeakInterface;
    
    public class DubboConsumer {
    	public static void main(String[] args) throws InterruptedException {
    		ApplicationContext context = new ClassPathXmlApplicationContext(
    				new String[] { "/spring/spring-*.xml" });
    
    		SpeakInterface speakInterface = context.getBean("speakInterface",
    				SpeakInterface.class); // 获取远程服务代理
    		People people = new People();
    		people.setAge(7);
    		System.out.println(speakInterface.speak(people));
    		// 用于观察zookeeper上节点信息的变化
    		Thread.sleep(115000);
    
    	}
    }

7、[源码下载][Link 1]

[20170116144135937]: /images/20220711/bde8e2955df44bb0a2f60f8a1ff8c403.png
[http_blog.csdn.net_zbw18297786698_article_details_53011449]: http://blog.csdn.net/zbw18297786698/article/details/53011449
[20170116132836027]: /images/20220711/b8f8b751b5504b6782e9f48170676572.png
[20170116134216913]: /images/20220711/7c1ab5c8cd0c4ad9b8dd813cd26f5e18.png
[20170116134654154]: /images/20220711/5053cf8b01a84a77aca6db755ba50c72.png
[20170116135059222]: /images/20220711/4e13df2fa7f44a4ab0122fbbd3a4509f.png
[20170116140022172]: /images/20220711/3eaf7449f840499e8d0e51483fd2858e.png
[Link 1]: http://download.csdn.net/detail/zbw18297786698/9738759