dubbo与springmvc的简单使用

什么是Dubbo?

dubbo是阿里巴巴公司开源的高性能优秀服务框架,通过高性能的RPC(远程服务调用)实现服务的输入输出功能,可以与spring框架无缝整合;

传统的架构所有的模块都在一台服务器上,单台服务器的性能毕竟有限,无法处理高并发,分布式服务将模块进行分离,通过多台服务器来分担一台服务器承受的压力。而多台服务器之间通信可以使用远程服务的调用。(自己理解的,如有不对还望指正);

Dubbo运行的原理:

1、Provider:服务的提供方;

2、ConSumer:调用远程服务的消费方;

3、Registry:服务注册与发现服务的注册中心(提供服务的一方在注册中心注册,消费者来到注册中心,注册中心提供给消费者已经注册服务的地址列表,消费者选择自己需要的服务去调用);

4、Monitor:统计服务的调用次数和时间;

5、Container:服务运行的容器;

(服务提供者:小张(生产汽车轮胎),注册中心:小册,服务消费者:小李(生产汽车的,需要轮胎);首先小张去找小册,注册一个自己的地址,说我这有最好的汽车轮胎,小张注册完了之后。小李又去找小册,说想要买轮胎来造汽车,小册就告诉小张,我这有卖汽车轮胎的地址,你去找他吧,然后小李就去找小张买轮胎,买来轮胎装在汽车上,在这整个过程中,还有一个小雅,它相当于Monitor,先有小张注册,然后小李来问过之后又去找过小张,它对着整个过程都做了记录。)

Dubbo的使用:

1、注册中心使用zookeeper:搭建zookeeper环境,在这里只是简单的使用dubbo,搭建一个单机版的zookeeper,不涉及集群,我使用的docker来搭建zookeeper,相对来说还是比较简单的。可以根据这个博客搭建    https://blog.csdn.net/qq_26641781/article/details/80886831

2、注册中心有了,然后开始敲代码:

  2.1、项目结构:

    

  一个聚合工程下创建三个子工程;其中controller是web项目,interface普通jar项目,service是web项目(创建项目就不详述了)  

  2.2、interface项目:只有一个接口TestInterface,

    

package top.interface1;public interface TestInterface {public String getData(String data);
}

 

  2.3、service项目(相当于提供者):对interface接口的实现,主要编写的TestService实现类,log4j文件,spring.xml文件,web.xml文件,pom.xml文件;

       

   由于需要使用到另一个项目的interface接口,先引入interface项目的依赖;

   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/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>top.free</groupId><artifactId>testdubbo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>service</artifactId><packaging>war</packaging><dependencies><!-- interface项目依赖,需要用到接口 --><dependency><groupId>top.free</groupId><artifactId>interface</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!-- springweb模块依赖 --><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>5.1.5.RELEASE</version></dependency><!-- dubbo相关依赖 --><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.6.2</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>2.8.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>2.8.0</version></dependency><!-- zookeeper客户端依赖 --><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.10</version>   </dependency></dependencies><build><plugins><!-- tomcat插件,端口是8081 --><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.2</version><configuration><uriEncoding>UTF-8</uriEncoding><port>8081</port><path>/</path></configuration></plugin></plugins></build>
</project>

  TestService实现类:注意加@service注解

package top.service;import org.springframework.stereotype.Service;import top.interface1.TestInterface;@Service
public class TestService implements TestInterface{@Overridepublic String getData(String data) {return "小张生产了轮胎,"+data+"来买走了";}}

  log4j.properties文件:

###set log levels###
log4j.rootLogger=info, stdout
###output to the console###
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target=System.out
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=[%d{dd/MM/yy hh:mm:ss:sss z}] %t %5p %c{2}: %m%n

   spring.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"xmlns:mvc="http://www.springframework.org/schema/mvc"xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsdhttp://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsdhttp://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.3.xsd">
  <!-- 扫描service包下的@Service注解 -->
  <context:component-scan base-package="top.service"></context:component-scan><!-- 发布服务到注册中心,告诉注册中心我这有轮胎 --><!-- 为服务起一个别名,别名可以随便起,最好能见名知意 --><dubbo:application name="testprovider"/><!--address 注册中心zookeeper的地址(替换成自己的地址)   protocol  指的是注册中心的协议的格式 --><dubbo:registry address="192.168.25.130:2181" protocol="zookeeper"/><!-- interface告诉注册中心是哪个类型 (这是轮胎)ref说明具体是哪个服务(实现类TestService的Bean名称,默认类名首字母小写)timeout连接超时的时间--><dubbo:service interface="top.interface1.TestInterface" ref="testService" timeout="60000"></dubbo:service><!--配置暴露服务端口(相当于这是轮胎厂的西门,只有这个开着,其他的都关着),协议是dubbo,消费者消费的时候必须通过端口来消费,端口可以随便写,但是不能被占用,一个dubbo,独占一个端口 --><dubbo:protocol name="dubbo" port="12345"></dubbo:protocol>
</beans>

  Web.xml文件:

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5"><display-name>service</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>
</filter>
  <filter-mapping>
    <filter-name>CharacterEncodingFilter</filter-name>
    <url-pattern>/*</url-pattern>
  </filter-mapping>
<!--加载spring的配置文件--><context-param><param-name>contextConfigLocation</param-name><param-value>classpath:spring.xml</param-value></context-param>
<!--spring监听器--><listener><listener-class>org.springframework.web.context.ContextLoaderListener</listener-class></listener> </web-app>

 2.4、controller项目(消费者):TestController类,log4j文件(与service一致),spring.xml文件,pom.xml文件,Web.xml文件;

 

 由于Controller中需要注入Interface接口,所以也需要引入Interface项目的依赖:

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/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><parent><groupId>top.free</groupId><artifactId>testdubbo</artifactId><version>0.0.1-SNAPSHOT</version></parent><artifactId>controller</artifactId><packaging>war</packaging><dependencies><!-- webmvc模块 --><dependency><groupId>org.springframework</groupId><artifactId>spring-webmvc</artifactId><version>5.1.5.RELEASE</version></dependency><!-- interface接口依赖 --><dependency><groupId>top.free</groupId><artifactId>interface</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!-- dubbo依赖 --><dependency><groupId>com.alibaba</groupId><artifactId>dubbo</artifactId><version>2.6.2</version> </dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-framework</artifactId><version>2.8.0</version></dependency><dependency><groupId>org.apache.curator</groupId><artifactId>curator-recipes</artifactId><version>2.8.0</version></dependency><!-- zookeeper依赖 --><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.10</version>   </dependency></dependencies><build><plugins><!-- tomcat插件,端口8082,与service项目端口不能一样 --><plugin><groupId>org.apache.tomcat.maven</groupId><artifactId>tomcat7-maven-plugin</artifactId><version>2.2</version><configuration><uriEncoding>UTF-8</uriEncoding><port>8082</port><path>/</path></configuration></plugin></plugins></build>
</project>

 TestController类:

package top.controller;import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;import top.interface1.TestInterface;@RestController
public class TestController {@Autowiredprivate TestInterface test;
    //produces防止显示json数据页面乱码@RequestMapping(value
="/test",produces = "text/json;charset=UTF-8" )public String getData(String user) {String data = test.getData(user);return data;} }

 spring.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"xmlns:mvc="http://www.springframework.org/schema/mvc"xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsdhttp://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsdhttp://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.3.xsd"><!--扫描controller包下的注解-->
  <context:component-scan base-package="top.controller"></context:component-scan><mvc:annotation-driven></mvc:annotation-driven><!-- 消费者起一个别名,可以随便起,最好见名知意 --><dubbo:application name="testconsumer"/><!--address 注册中心的地址 protocol 指的是注册中心的协议的格式 --><dubbo:registry address="192.168.25.130:2181" protocol="zookeeper"/><!-- 告诉注册中心我需要一个轮胎,interface是Interface项目中的接口全路径 id指的是bean的引用 --><dubbo:reference interface="top.interface1.TestInterface" id="testInterface"></dubbo:reference></beans>

 Web.xml文件:

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" version="2.5"><display-name>controller</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></filter><filter-mapping><filter-name>CharacterEncodingFilter</filter-name>
          <url-pattern>/*</url-pattern></filter-mapping>
<!--springmvc的前端控制器--><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.xml</param-value></init-param><load-on-startup>1</load-on-startup></servlet>
<!--拦截以.do结尾的所有请求--><servlet-mapping><servlet-name>springmvc</servlet-name><url-pattern>*.do</url-pattern></servlet-mapping> </web-app>

至此配置完成;

 测试:

  首先安装整个聚合工程到本地,在聚合工程上右键run as-------》Maven install;安装过程中没报错,配置成功;

   启动service项目:在service项目上右键:Run as ------》Maven build...(注意是有三个点的)------》会出现如下界面:

  

   启动controller项目:与service步骤一致,命令不变;

 在浏览器中输入localhost:8082/test.do?user=张三(这里访问的是controller项目启动的tomcat端口)

dubbo的简单使用完成;

如果启动时遇到:

[ERROR] Failed to execute goal org.apache.maven.plugins:maven-clean-plugin:2.5:clean (default-clean) on project controller: Failed to clean project: Failed to delete E:\Spring STS程序\testdubbo\controller\target\tomcat\logs\access_log.2019-05-16 -> [Help 1]
[ERROR] 
[ERROR] To see the full stack trace of the errors, re-run Maven with the -e switch.
[ERROR] Re-run Maven using the -X switch to enable full debug logging.
[ERROR] 
[ERROR] For more information about the errors and possible solutions, please read the following articles:
[ERROR] [Help 1] http://cwiki.apache.org/confluence/display/MAVEN/MojoExecutionException

 有相同的启动程序未关闭:点击打开会看到有未关闭的,关闭之后重新启动;(启动顺序是先启动service,再启动controller,否则先启动controller会因为查找不到服务而报错)

转载于:https://www.cnblogs.com/YpfBolg/p/10878349.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/462571.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Mina学习之搭建项目工程目录

为什么80%的码农都做不了架构师&#xff1f;>>> Mina核心分层分为&#xff1a;IoService,IoFilter和IoHandler 搭建项目工程目录&#xff0c;一般应用都包含如下几个部分&#xff1a; 1、server\client 创建mina连接&#xff0c;TCP/IP请求响应模式 …

HttpClient中转上传文件

原文&#xff1a;https://www.cnblogs.com/lyxy/p/5629151.html 场景&#xff1a;客户端(浏览器)A---->选择文件上传---->服务器B---->中转文件---->服务器C---->返回结果---->服务器B---->客户端A 有时候在项目中需要把上传的文件中转到第三方服务器&…

sublime text 2快捷键总结

为什么80%的码农都做不了架构师&#xff1f;>>> 以mac系统为例 一&#xff1a;编辑&#xff08;我们使用一个编辑器最频繁的事情就是编辑了。&#xff09; &#xff08;1&#xff09;基本操作&#xff1a; 【1】CommandA:全选 【2】CommandC:复制 【3】Comman…

Spring Boot 2.1.5 正式发布,1.5.x 即将结束使命!

Spring Boot 官网在 2019/03/15 这天发布了 Spring Boot 2.1.5 正式版&#xff0c;栈长表示真跟不上了。。 官宣如下 &#xff1a; https://spring.io/blog/2019/05/15/spring-boot-2-1-5-released 仓库也已经跟上&#xff1a; 那这个版本有什么新功能&#xff1f; 1、增加了 S…

Console-算法[for,if]-有5个人坐在一起,问第五个人多少岁?他说比第4个人大2岁。问第4个人岁数...

ylbtech-Arithmetic:Console-算法[for,if]-有5个人坐在一起&#xff0c;问第五个人多少岁&#xff1f;他说比第4个人大2岁。问第4个人岁数1.A&#xff0c;Demo(案例)【程序28】 题目&#xff1a;有5个人坐在一起&#xff0c;问第五个人多少岁&#xff1f;他说比第4个人大2岁。问…

原来MySQl就是这样工作的

一、MySQL简单介绍MySQL是当今最流行的开源数据库管理系统&#xff0c;超过10亿的下载量足可以证明这点。MySQL以其速度、高可靠性、简单易用&#xff0c;广泛应用,一些大型企业也在逐渐应用&#xff0c;如&#xff1a;Facebook、维基百科等网站。MySQL最早由瑞典的MySQL AB公司…

Java生成二进制文件与Postman以二进制流的形式发送请求

业务描述&#xff1a; 模拟终端&#xff08;智能家居&#xff09;发送HTTP POST请求&#xff0c;请求参数为二进制流&#xff1b;而且&#xff0c;二进制流是加密后的数据&#xff0c;因此调试分两步&#xff1a; 1、Java代码生成加密后数据&#xff0c;并保存为二进制流文件 &…

电脑上面玩Android 游戏(.apk文件)

Android模拟器, 下载地址 http://files.cnblogs.com/jx270/BlueStacks-SplitInstaller_native.rar 下载完毕后解压&#xff0c;双击安装, 然后自己去下一些.apk文件&#xff0c;双击即可在电脑上面使用 ps自己配一个手柄,玩游戏不错,

JQuery最佳实践

作者&#xff1a; 阮一峰 日期&#xff1a; 2011年8月 4日 上周&#xff0c;我整理了《jQuery设计思想》。 那篇文章是一篇入门教程&#xff0c;从设计思想的角度&#xff0c;讲解"怎么使用jQuery"。今天的文章则是更进一步&#xff0c;讲解"如何用好jQuery&quo…

Excel-在整个工作簿中查找/替换

13、在整个工作簿中查找/替换 调范围为&#xff1a;工作簿&#xff0c;默认是工作表&#xff1b; 转载于:https://www.cnblogs.com/Formulate0303/p/10885194.html

WCF服务实例激活类型编程与开发(转)

【引言】&#xff1a; 在WCF分布式开发必备知识(2):.Net Remoting这 篇文章里我已经介绍过了Net Remoting相关的概念&#xff0c;其中也包括Net Remoting的激活方式&#xff1a;SingleTon模式、SingleCall模式、客户端激活方式。其实WCF服务的激活方式也与此相似。服务激活方式…

部署Windows Server Update Services 4.0

在 Windows Server 2012 中&#xff0c;WSUS 是可安装以管理和分配更新的服务器角色。WSUS 服务器可以作为组织内其他 WSUS 服务器的更新源。充当更新源的 WSUS 服务器被称为上游服务器。在 WSUS 实现过程中&#xff0c;网络中必须至少有一台 WSUS 服务器连接到 Microsoft 更新…

克罗谈投资策略09

第七章 把注意力集中在长期趋势上&#xff08;2&#xff09; 我接到很多交易者寄来的信和打来的电话&#xff0c;谈论投机交易的各个层面。但是其中匹兹堡一位专业交易者1984年8月所写的一封信&#xff0c;跟上面所说的主题有特别的关联&#xff1a; 大家都说在目前的市场情况下…

《统计学习方法》(李航)读书笔记(转)

《统计学习方法》(李航)读书笔记(转) http://www.cnblogs.com/limitlessun/p/8611103.html#_label4阅读目录 知识点感知机k近邻法朴素贝叶斯决策树logistic回归和最大熵模型支持向量机提升方法EM算法隐马尔可夫模型(HMM)统计学习方法总结神经网络K-MeansBaggingApriori降维方法…

html奇淫技巧 2 教你如何进行图文环绕布局 原创

在群里无意看到了盆友想要布局一个图文环绕的布局&#xff0c;问有没有什么办法实现&#xff0c;上网查了下&#xff0c;都感觉忽悠人的。 js 方面学的不怎么好&#xff0c;但是页面这块是不服输的。 于是就进行了研究&#xff0c;需求如下&#xff1a; 起先看到这张需求我是有…

Lync与Exchange 2013 UM集成:Lync Server配置

在完成了对Exchange的UM功能进行配置之后&#xff0c;我们要把UM的功能与Lync做集成的话还需要在Lync这边做一些配置。首先我们打开Lync前端服务器&#xff0c;然后打开核心组件安装目录下的Support文件夹&#xff0c;然后双击OcsUmUtil。打开之后我们单击加载数据&#xff0c;…

在ubuntu中为程序添加图标快捷键

2019独角兽企业重金招聘Python工程师标准>>> 比如我在我的ubuntu上安装了javaEE eclipse&#xff0c;这个软件直接解压就可以用&#xff0c;这时在导航栏里没有对应图标&#xff0c;在左上角的软件中心中也没有图标&#xff0c;每次启动它得用命令来启动&#xff0c…

更改消息存储的位置

2019独角兽企业重金招聘Python工程师标准>>> 更改消息存储的位置 将消息存储位置更改为另一目录或文件系统。 开始之前 记录部署至要配置的集群的 IBM Lotus Connections 功能部件。 关于此任务 集群成员多于一个节点时&#xff0c;消息存储必须对集群中位于相同物…

【原创】StreamInsight查询系列(三)——基本查询操作之过滤

上篇博文介绍了如何在LINQPad中输出StreamInsight查询结果。这篇文章将主要介绍StreamInsight基础查询操作中的过滤部分。 测试数据准备 为了方便测试查询&#xff0c;我们首先准备一个静态的测试数据源&#xff1a;var weatherData new[] {new { Timestamp new DateTime(201…

设计模式之四(抽象工厂模式第二回合)

前言 在第一回合中留下的问题&#xff0c;http://www.cnblogs.com/aehyok/archive/2013/05/19/3087497.html&#xff0c;现在就先处理一个简单的&#xff0c;只添加一个Department表。 第二回合 首先要建立部门类&#xff0c;假设只有两个字段部门ID&#xff0c;和部门名称。 p…