dubbo web工程示例_分布式开发-Zooker+dubbo入门-Demo
作者:知了堂-劉陽(yáng)
1.什么是SOA架構(gòu)
SOA 是Service-Oriented Architecture的首字母簡(jiǎn)稱,它是一個(gè)面向服務(wù)的架構(gòu)模式(俗稱:分布式;面服務(wù)的分布式)
為什么互聯(lián)網(wǎng)項(xiàng)目會(huì)采用SOA架構(gòu)呢?隨著互聯(lián)網(wǎng)的發(fā)展,網(wǎng)站應(yīng)用的規(guī)模不斷擴(kuò)大,常規(guī)的垂直應(yīng)用架構(gòu)已無(wú)法應(yīng)對(duì),分布式服務(wù)架構(gòu)以及流動(dòng)計(jì)算架構(gòu)勢(shì)在必行。
2.Dubbo框架
Dubbo是一個(gè)分布式框架,由阿里巴巴團(tuán)隊(duì)開(kāi)發(fā)的開(kāi)源項(xiàng)目,在電商系統(tǒng)(高可用,高并發(fā),高擴(kuò)展)廣泛的用用
Dubbo也是RPC遠(yuǎn)程服務(wù)調(diào)用一套解決方案,以及SOA服務(wù)治理方案
3.Dubbo框架原理
節(jié)點(diǎn)角色說(shuō)明:
· Provider: 暴露服務(wù)的服務(wù)提供方。
· Consumer: 調(diào)用遠(yuǎn)程服務(wù)的服務(wù)消費(fèi)方。
· Registry: 服務(wù)注冊(cè)與發(fā)現(xiàn)的注冊(cè)中心。
· Monitor: 統(tǒng)計(jì)服務(wù)的調(diào)用次調(diào)和調(diào)用時(shí)間的監(jiān)控中心。
· Container: 服務(wù)運(yùn)行容器。
調(diào)用關(guān)系說(shuō)明:
· 0. 服務(wù)容器負(fù)責(zé)啟動(dòng),加載,運(yùn)行服務(wù)提供者。
· 1. 服務(wù)提供者在啟動(dòng)時(shí),向注冊(cè)中心注冊(cè)自己提供的服務(wù)。
· 2. 服務(wù)消費(fèi)者在啟動(dòng)時(shí),向注冊(cè)中心訂閱自己所需的服務(wù)。
· 3. 注冊(cè)中心返回服務(wù)提供者地址列表給消費(fèi)者,如果有變更,注冊(cè)中心將基于長(zhǎng)連接推
送變更數(shù)據(jù)給消費(fèi)者。
· 4. 服務(wù)消費(fèi)者,從提供者地址列表中,基于軟負(fù)載均衡算法,選一臺(tái)提供者進(jìn)行調(diào)用,
如果調(diào)用失敗,再選另一臺(tái)調(diào)用。
· 5. 服務(wù)消費(fèi)者和提供者,在內(nèi)存中累計(jì)調(diào)用次數(shù)和調(diào)用時(shí)間,定時(shí)每分鐘發(fā)送一次統(tǒng)計(jì)
數(shù)據(jù)到監(jiān)控中心。
4.zookeeper + dubbo 的入門(mén)demo
思路:
(1)根據(jù)dubbo的原理圖,案例中涉及到兩個(gè)服務(wù):服務(wù)提供者;服務(wù)消費(fèi)者
(2)技術(shù)棧:spring+dubbo+zookeeper
(3)服務(wù)提供者:service層提供
(4)服務(wù)消費(fèi)者:controller層提供
(5)但是兩個(gè)程序不在同一個(gè)web服務(wù)器上,我們會(huì)設(shè)置兩個(gè)服務(wù)端口8081;8082
(6)zookeeper就是我們服務(wù)的注冊(cè)中心
服務(wù)提供者編碼
(1)創(chuàng)建maven工程,在pom.xml中引入依賴,同時(shí)打tomcat7-maven-plugin的插件
dubbo框架的版本 2.5.3,不支持最新的spring5.x的版本,目前的版本是spring4.x的版本
加入log4j的依賴包【重要】
log4j.rootLogger=INFO,Console log4j.appender.Console=org.apache.log4j.ConsoleAppender log4j.appender.Console.Target=System.out log4j.appender.Console.layout = org.apache.log4j.PatternLayout log4j.appender.Console.layout.ConversionPattern=[%c] - %m%n<?xml version="1.0" encoding="UTF-8"?><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.zlt</groupId><artifactId>dubbocustomer</artifactId><version>1.0-SNAPSHOT</version><packaging>war</packaging><name>dubbocustomer Maven Webapp</name><!-- FIXME change it to the project's website --><url>http://www.example.com</url><properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><maven.compiler.source>1.7</maven.compiler.source><maven.compiler.target>1.7</maven.compiler.target></properties><dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.11</version><scope>test</scope></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>4.0.3.RELEASE</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.5.3</version><exclusions><exclusion><groupId>org.springframework</groupId><artifactId>spring</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>log4j</groupId><artifactId>log4j</artifactId><version>1.2.16</version></dependency></dependencies><build><finalName>dubbocustomer</finalName><pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) --><plugins><plugin><artifactId>maven-clean-plugin</artifactId><version>3.1.0</version></plugin><!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_war_packaging --><plugin><artifactId>maven-resources-plugin</artifactId><version>3.0.2</version></plugin><plugin><artifactId>maven-compiler-plugin</artifactId><version>3.8.0</version></plugin><plugin><artifactId>maven-surefire-plugin</artifactId><version>2.22.1</version></plugin><plugin><artifactId>maven-war-plugin</artifactId><version>3.2.2</version></plugin><plugin><artifactId>maven-install-plugin</artifactId><version>2.5.2</version></plugin><plugin><artifactId>maven-deploy-plugin</artifactId><version>2.8.2</version></plugin><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.2</version><configuration><port>8082</port><path>/</path><uriEncoding>UTF-8</uriEncoding><server>tomcat7</server></configuration></plugin></plugins></pluginManagement></build> </project>(2)在工程的web.xml文件添加加載spring.xml配置文件的代碼
<!DOCTYPE web-app PUBLIC"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN""http://java.sun.com/dtd/web-app_2_3.dtd" ><web-app><display-name>Archetype Created Web Application</display-name><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:spring/spring.xml</param-value></context-param><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener> </web-app>(3)編寫(xiě)spring.xml文件,加入dubbo.xsd的配置
<?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.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><dubbo:application name="dubboprovider"></dubbo:application><dubbo:registry address="zookeeper://192.168.0.105:2181"></dubbo:registry><dubbo:annotation package="com.zlt.service"></dubbo:annotation></beans>(4)創(chuàng)建UserService
package com.zlt.service;public interface UserService {public String getName(); }(5)創(chuàng)建UserServiceImpl,添加@Service注解,但是@Service注解來(lái)自dubbo包
package com.zlt.service.impl;import com.alibaba.dubbo.config.annotation.Service; import com.zlt.service.UserService;@Service public class UserServiceImpl implements UserService {@Overridepublic String getName() {return "zhiliaotang...";}}(6)通過(guò)maven來(lái)運(yùn)行項(xiàng)目工程
命令:tomcat7:run,此命令是一個(gè)maven命令。如果第一次加入tomcat7-maven-plugin,需要在運(yùn)行此命令的時(shí)候進(jìn)行插件的下載
(7)tomcat7-maven-plugin插件命令【擴(kuò)展】
tomcat7:run,啟動(dòng)嵌入tomcat,并運(yùn)行當(dāng)前項(xiàng)目
tomcat7:deploy,部署一個(gè)web war包
tomcat7:reload,重新加載web war包
tomcat7:start,啟動(dòng)tomcat
tomcat7:stop,停止tomcat
tomcat7:undeploy,停止一個(gè)web war包
服務(wù)消費(fèi)方編碼
(1)繼續(xù)創(chuàng)建maven-webapp工程,pom.xml代碼和前面的一樣
(2)創(chuàng)建spring-mvc.xml配置文件
(3)在web.xml文件,加載spring-mvc.xml配置文件,并設(shè)置好SpringMVC的核心控制器
<!DOCTYPE web-app PUBLIC"-//Sun Microsystems, Inc.//DTD Web Application 2.3//EN""http://java.sun.com/dtd/web-app_2_3.dtd" ><web-app><display-name>Archetype Created Web Application</display-name><filter><filter-name>characterEncodingFilter</filter-name><filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class><init-param><param-name>encoding</param-name><param-value>utf-8</param-value></init-param><init-param><param-name>forceEncoding</param-name><param-value>true</param-value></init-param></filter><filter-mapping><filter-name>characterEncodingFilter</filter-name><url-pattern>/*</url-pattern></filter-mapping><servlet><servlet-name>springmvc</servlet-name><servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class><init-param><param-name>contextConfigLocation</param-name><param-value>classpath:spring/spring-mvc.xml</param-value></init-param></servlet><servlet-mapping><servlet-name>springmvc</servlet-name><url-pattern>/</url-pattern></servlet-mapping> </web-app>(3)拷貝業(yè)務(wù)接口到dubbocustomer項(xiàng)目工程里面
(4)創(chuàng)建IndexController,同時(shí)依賴UserService接口。注意:這里通過(guò)阿里的@Reference注解完成依賴關(guān)系
package com.zlt.controller;import com.alibaba.dubbo.config.annotation.Reference; import com.zlt.service.UserService; import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping;@Controller public class IndexController {@Referenceprivate UserService userService; // 依賴注入U(xiǎn)serService@RequestMapping("/index")@ResponseBodypublic String index() {return userService.getName();}}(5)修改spring-mvc.xml配置文件,加入阿里的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:mvc="http://www.springframework.org/schema/mvc"xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsdhttp://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd"><mvc:annotation-driven></mvc:annotation-driven><dubbo:application name="dubbocustomer"></dubbo:application><dubbo:registry address="zookeeper://192.168.1.19:2181"></dubbo:registry><dubbo:annotation package="com.zlt.controller"></dubbo:annotation></beans>(6)測(cè)試,http://localhost:8082/index,通過(guò)8082的端口中index接口去訪問(wèn)8081端口中的service。
今天的分享先到這兒了,更多編程學(xué)習(xí)干貨,請(qǐng)關(guān)注專欄:
知了編程學(xué)習(xí)圈?zhuanlan.zhihu.com總結(jié)
以上是生活随笔為你收集整理的dubbo web工程示例_分布式开发-Zooker+dubbo入门-Demo的全部?jī)?nèi)容,希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇: java 线程状态_浅析Java中的线程
- 下一篇: a标签传值到另一个页面_vue-rout