1. 程式人生 > >Dubbo(五) Dubbo入門demo——helloworld

Dubbo(五) Dubbo入門demo——helloworld

端口號 80端口 databind hot 找不到 body fun ide 說明

前言

前面我已經介紹了dubbo的一些基本工具和知識,讓大家簡單的了解了下RPC框架和Dubbo。接下來就是重點了,Dubbo的helloworld項目。技術分享圖片

一、搭建項目

首先我們新建三個maven項目如下圖:
技術分享圖片

  • dubbo-provider(服務提供者)
  • dubbo-api(api提供者)
  • dubbo-consumer(消費者)
    技術分享圖片

OKOK!這裏我們再簡單介紹下API項目。我前面說了,只有消費者和生產者是沒錯的。but你想啊,你在生產者項目中要用接口,消費者中要用接口,是是不是兩個項目都TM要寫同樣的代碼啊,那多麻煩!!

所以這裏我們用一個項目把需要的公共代碼丟進去,一些接口啊,實體啊啥的,然後打成jar包導入到生產者和消費者中,多完美。


API項目:

由於helloworld的demo過於簡單,這裏我們就丟一個公共接口放裏面。

package com.provider;
/**
* ClassName:DemoService
* Function: TODO ADD FUNCTION.
* Date: 2017年11月28日 下午6:43:49
* @author HXY
*/
public interface DemoService {
String sayHello(String name);
}

然後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/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>hxy.superFather.forJava</groupId> <artifactId>dubbo-api</artifactId> <packaging>jar</
packaging> <version>0.0.1-SNAPSHOT</version> <name>dubbo-api Maven Webapp</name> <url>http://maven.apache.org</url> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> </dependencies> <build> <finalName>dubbo-api</finalName> </build> </project>


provider項目:

接口實現類:

package com.provider.impl;
import com.bean.User;
import com.provider.DemoService;
/**
* ClassName:DemoServiceImpl
* Function: TODO ADD FUNCTION.
* Date: 2017年11月29日 上午9:31:23
* @author HXY
*/
public class DemoServiceImpl implements DemoService {
@Override
public String sayHello(String name) {
return "Hello " + name;
}
}

服務註冊啟動類:

package com;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class Provider {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "provider.xml" });
context.start();
System.in.read(); // 為保證服務一直開著,利用輸入流的阻塞來模擬
}
}

spring整合dubbo配置文件provider.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-provider-app" />
<!-- 使用zookeeper註冊中心暴露服務地址 -->
<!-- 使用multicast廣播註冊中心暴露服務地址 -->
<!-- <dubbo:registry address="multicast://224.5.6.7:1234" /> -->
<!-- 用dubbo協議在20880端口暴露服務 -->
<dubbo:protocol name="dubbo" port="20880" />
<!-- 使用zookeeper註冊中心暴露服務地址 -->
<dubbo:registry address="zookeeper://127.0.0.1:2181?backup=127.0.0.1:2182,127.0.0.1:2183" />
<!-- 聲明需要暴露的服務接口 -->
<dubbo:service interface="com.provider.DemoService" ref="demoService" />
<!-- 和本地bean一樣實現服務 -->
<bean id="demoService" class="com.provider.impl.DemoServiceImpl" />
</beans>

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/maven-v4_0_0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>dubbo</groupId>
<artifactId>dubbo-provider</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>dubbo-provider Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<!-- spring版本號 -->
<spring.version>4.0.2.RELEASE</spring.version>
<!-- mybatis版本號 -->
<mybatis.version>3.2.6</mybatis.version>
<!-- log4j日誌文件管理包版本 -->
<slf4j.version>1.7.7</slf4j.version>
<log4j.version>1.2.17</log4j.version>
<!-- shiro版本號 -->
<shiro.version>1.2.3</shiro.version>
</properties>
<dependencies>
<!-- 6 dubbo zookeeper相關依賴start -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
<exclusions>
<exclusion>
<groupId>org.springframework</groupId>
<artifactId>spring</artifactId>
</exclusion>
<exclusion>
<groupId>org.jboss.netty</groupId>
<artifactId>netty</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>com.github.sgroschupf</groupId>
<artifactId>zkclient</artifactId>
<version>0.1</version>
</dependency>
<dependency>
<groupId>hxy.superFather.forJava</groupId>
<artifactId>dubbo-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
<!-- junit配置 -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>3.8.1</version>
<scope>test</scope>
</dependency>
<!-- 導入java ee jar 包 -->
<dependency>
<groupId>javax</groupId>
<artifactId>javaee-api</artifactId>
<version>7.0</version>
</dependency>
<!-- spring核心包 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-oxm</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-jdbc</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-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<!-- json數據 -->
<dependency>
<groupId>org.codehaus.jackson</groupId>
<artifactId>jackson-core-asl</artifactId>
<version>1.9.13</version>
</dependency>
<dependency>
<groupId>net.sf.json-lib</groupId>
<artifactId>json-lib</artifactId>
<version>2.4</version>
<classifier>jdk15</classifier>
</dependency>
<dependency>
<groupId>org.codehaus.jackson</groupId>
<artifactId>jackson-mapper-asl</artifactId>
<version>1.9.13</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-annotations</artifactId>
<version>2.8.5</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-core</artifactId>
<version>2.7.7</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.8.9</version>
</dependency>
<!-- JSTL標簽類 -->
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
</dependencies>
<build>
<finalName>dubbo-provider</finalName>
</build>
</project>


DubboConsummer項目:

消費類:

public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "spring-common.xml" });
context.start();
for(int i = 0;i<10;i++){
DemoService demoService = (DemoService) context.getBean("demoService");
String hello = demoService.sayHello("tom");
System.out.println("-------------"+hello);
Thread.sleep(5000);
}
System.in.read();
System.out.println("end");
}

spring整合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:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context"
xmlns:task="http://www.springframework.org/schema/task"
xsi:schemaLocation="
http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context.xsd
http://www.springframework.org/schema/task
http://www.springframework.org/schema/task/spring-task-3.0.xsd">
<import resource="classpath:spring-dubbo.xml"/>
</beans>
<?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="counmser" />
<!-- 使用multicast廣播註冊中心暴露服務地址 -->
<!--<dubbo:registry address="multicast://224.5.6.7:1234" /> -->
<!-- 使用zookeeper註冊中心暴露服務地址 即zookeeper的所在服務器ip地址和端口號 -->
<dubbo:registry address="zookeeper://127.0.0.1:2181?backup=127.0.0.1:2182,127.0.0.1:2183" />
<!-- 生成遠程服務代理,可以像使用本地bean一樣使用demoService -->
<dubbo:reference id="demoService"
interface="com.provider.DemoService" />
</beans>



二、運行

在正常項目部署中,我們會打包成可執行的jar文件啟動,就還需要配置pom才能讓maven打包。

但是這個我們後續再講,今天的demo我們就用eclipse的main方法執行了,原理其實一樣的。

  1. 首先打開zookeeper工具
  2. 啟動服務提供者,他會自動註冊到配置文件配置的zookeeper中
  3. 啟動消費者,調用服務

技術分享圖片

然後看到這樣的打印,說明成功了,dubbo的基本使用原理在做helloworld項目過程中,也應該有了大致了解。

三、其他問題解決

  • spring-dubbo整合的配置文件中,dubbo配置項紅叉報錯問題。
    原因
    因為dubbo.xsd文件找不到吧,好像是這個原因!
    解決方案
    1. 到maven庫中找到dubbo的jar包,將其解壓。
    2. 找到解壓文件夾下的META-INF文件夾下的dubbo.xsd。
    3. eclipse選擇windows->preferrence->xml->xml Catalog,右側add-xml文件,在文件目錄中選擇dubbo.xsd。
    4. 下面的key值填寫配置文件中一致的 http://code.alibabatech.com/schema/dubbo/dubbo.xsd
      如下圖:技術分享圖片
      確定完成之後重新驗證配置文件即可。






      謝謝點擊:http://www.droptb.com/article/detail/0eb59155f8b9434d99d8875a900ea750

Dubbo(五) Dubbo入門demo——helloworld