java 分布式rpc框架_分布式RPC框架Apache Dubbo(一)

4 Dubbo快速入门

Dubbo作为一个RPC框架，其最核心的功能就是要实现跨网络的远程调用。本小节就是要创建两个应用，一个作为服务的提供方，一个作为服务的消费方。通过Dubbo来实现服务消费方远程调用服务提供方的方法。

4.1 服务提供方开发

开发步骤：

(1)创建maven工程(打包方式为war)dubbodemo_provider，在pom.xml文件中导入如下坐标

war

UTF-8

1.8

1.8

5.0.5.RELEASE

org.springframework

spring-context

${spring.version}

org.springframework

spring-beans

${spring.version}

org.springframework

spring-webmvc

${spring.version}

org.springframework

spring-jdbc

${spring.version}

org.springframework

spring-aspects

${spring.version}

org.springframework

spring-jms

${spring.version}

org.springframework

spring-context-support

${spring.version}

com.alibaba

dubbo

2.6.0

org.apache.zookeeper

zookeeper

3.4.7

com.github.sgroschupf

zkclient

0.1

javassist

javassist

3.12.1.GA

com.alibaba

fastjson

1.2.47

org.apache.maven.plugins

maven-compiler-plugin

2.3.2

1.8

1.8

org.apache.tomcat.maven

tomcat7-maven-plugin

8081

/

(2)配置web.xml文件

创建 webapp/WEB-INF/web.xml

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"

version="3.1">

contextConfigLocation

classpath:applicationContext*.xml

org.springframework.web.context.ContextLoaderListener

(3)创建服务接口

package com.maweiqi.service;

/**

* HelloService

*

* @Author: 马 伟 奇

* @CreateTime: 2019-07-18

* @Description:

*/

public interface HelloService {

public String sayHello(String name);

}

(4)创建服务实现类

package com.maweiqi.service.impl;

import com.alibaba.dubbo.config.annotation.Service;

import com.maweiqi.service.HelloService;

/**

* HelloServiceImpl

*

* @Author: 马 伟 奇

* @CreateTime: 2019-07-18

* @Description:

*/

@Service

public class HelloServiceImpl implements HelloService {

@Override

public String sayHello(String name) {

return "hello " + name;

}

}

注意：服务实现类上使用的Service注解是Dubbo提供的，用于对外发布服务

(5)在src/main/resources下创建applicationContext-service.xml

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:p="http://www.springframework.org/schema/p"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xmlns:mvc="http://www.springframework.org/schema/mvc"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans.xsd

http://www.springframework.org/schema/mvc

http://www.springframework.org/schema/mvc/spring-mvc.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context.xsd">

(6)启动服务

1941e4f04dce

启动服务

4.2 服务消费方开发

开发步骤：

(1)创建maven工程(打包方式为war)dubbodemo_consumer，pom.xml配置和上面服务提供者相同，只需要将Tomcat插件的端口号改为8082即可

war

UTF-8

1.8

1.8

5.0.5.RELEASE

org.springframework

spring-context

${spring.version}

org.springframework

spring-beans

${spring.version}

org.springframework

spring-webmvc

${spring.version}

org.springframework

spring-jdbc

${spring.version}

org.springframework

spring-aspects

${spring.version}

org.springframework

spring-jms

${spring.version}

org.springframework

spring-context-support

${spring.version}

com.alibaba

dubbo

2.6.0

org.apache.zookeeper

zookeeper

3.4.7

com.github.sgroschupf

zkclient

0.1

javassist

javassist

3.12.1.GA

com.alibaba

fastjson

1.2.47

org.apache.maven.plugins

maven-compiler-plugin

2.3.2

1.8

1.8

org.apache.tomcat.maven

tomcat7-maven-plugin

8082

/

(2)配置web.xml文件

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_3_1.xsd"

version="3.1">

springmvc

org.springframework.web.servlet.DispatcherServlet

contextConfigLocation

classpath:applicationContext-web.xml

1

springmvc

/

(3)将服务提供者工程中的HelloService接口复制到当前工程

package com.maweiqi.service;

/**

* HelloService

*

* @Author: 马伟奇

* @CreateTime: 2019-07-18

* @Description:

*/

public interface HelloService {

public String sayHello(String name);

}

(4)编写Controller

package com.maweiqi.controller;

import com.alibaba.dubbo.config.annotation.Reference;

import com.maweiqi.service.HelloService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

/**

* HelloController

*

* @Author: 马伟奇

* @CreateTime: 2019-07-19

* @Description:

*/

@Controller

@RequestMapping("/demo")

public class HelloController {

@Reference

private HelloService helloService;

@RequestMapping("/hello")

@ResponseBody

public String getName(String name){

//远程调用

String result = helloService.sayHello(name);

System.out.println(result);

return result;

}

}

注意：Controller中注入HelloService使用的是Dubbo提供的@Reference注解

(5)在src/main/resources下创建applicationContext-web.xml

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns:p="http://www.springframework.org/schema/p"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"

xmlns:mvc="http://www.springframework.org/schema/mvc"

xsi:schemaLocation="http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans.xsd

http://www.springframework.org/schema/mvc

http://www.springframework.org/schema/mvc/spring-mvc.xsd

http://code.alibabatech.com/schema/dubbo

http://code.alibabatech.com/schema/dubbo/dubbo.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context.xsd">

(6)运行测试

1941e4f04dce

运行

在浏览器输入http://localhost:8082/demo/hello?name=Jack，查看浏览器输出结果

4.3 代码重构

① 创建项目：dubbodemo_interface

1941e4f04dce

创建项目

② 把 项目dubbodemo_consumer 和 项目dubbodemo_provider当中的 接口 HelloService 拷贝到dubbodemo_interface工程里面

1941e4f04dce

image.png

③ 删除工程dubbodemo_consumer 和 工程dubbodemo_provider当中的 接口 HelloService

1941e4f04dce

image.png

dubbodemo_consumer 工程和dubbodemo_provider添加pom文件的依赖

com.maweiqi

dubbodemo_interface

1.0-SNAPSHOT

1941e4f04dce

获取数据

5. Dubbo管理控制台

我们在开发时，需要知道Zookeeper注册中心都注册了哪些服务，有哪些消费者来消费这些服务。我们可以通过部署一个管理中心来实现。其实管理中心就是一个web应用，部署到tomcat即可。

5.1 安装

安装步骤：

(1)将资料中的dubbo-admin-2.6.0.war文件复制到tomcat的webapps目录下

1941e4f04dce

image.png

(2)启动tomcat，此war文件会自动解压

1941e4f04dce

image.png

(3)修改WEB-INF下的dubbo.properties文件，注意dubbo.registry.address对应的值需要对应当前使用的Zookeeper的ip地址和端口号

dubbo.registry.address=zookeeper://192.168.134.129:2181

dubbo.admin.root.password=root

dubbo.admin.guest.password=guest

1941e4f04dce

image.png

(4)重启tomcat

5.2 使用

操作步骤：

1941e4f04dce

image.png

(2)启动服务提供者工程和服务消费者工程，可以在查看到对应的信息

1941e4f04dce

image.png

1941e4f04dce

image.png

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

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

相关文章

轻松获知数据库事务

轻松获知数据库事务

标题索引事务作用事务流程隔离级别实例验证事务作用事务是确保数据库系统数据的完整性的功能，如现在互联网行业支付业务，不管服务器出于什么原因异常中断，客户要么支付成功要么支付不成功，支付成功数据库金额即会发生变化&#xf…
阅读更多...
Python冒泡排序（4）

Python冒泡排序（4）

Python代码： """ 冒泡排序（4）在未排序的数中，通过两两比较[换位]的方式，将最小的数移至首位 N个数排序，则需要执行N-1轮，第1轮比较N-1次，后续每轮比上一轮少比较1次本…
阅读更多...
打印hello world java_java – 如何打印“hello world”？

打印hello world java_java – 如何打印“hello world”？

数字4946144450195624适合64位，其二进制表示为：10001100100100111110111111110111101100011000010101000该程序对每5位组的字符进行解码，从右到左00100|01100|10010|01111|10111|11111|01111|01100|01100|00101|01000d | l | r | o | w | | o…
阅读更多...
研发人员为什么留不住

研发人员为什么留不住

研发人员为什么留不住？(1)——问题与现象 研发团队做为公司的核心，承担了完成项目为公司赚钱的目的。研发人员在公司倍受重视的同时，并没有降低流失率。 问题与现象 以下问题相信您会在朋友口中，甚至自己的公司听到。 老板说&a…
阅读更多...
算法与编程--1

算法与编程--1

1、编写一个程序，将a.txt文件中的单词与b.txt文件中的单词交替合并到c.txt文件中，a.txt文件中的单词用回车符分隔，b.txt文件中用回车或空格进行分隔。 package com.test;import java.io.File; import java.io.FileNotFoundException; import …
阅读更多...
Safari支不支持HTML5录音？ 现在浏览器中最好的解决方案是WebRTC下的 navigator.getUserMedia API。...

Safari支不支持HTML5录音？ 现在浏览器中最好的解决方案是WebRTC下的 navigator.getUserMedia API。...

先放结论：Safari支不支持HTML5录音？ ——据我调查，不支持。 现在浏览器中最好的解决方案是WebRTC下的 navigator.getUserMedia API。 可是当使用Can I use查看兼容性的时候，我发现 不过这个是有历史原因的，我记得RTC是…
阅读更多...
python lambda map reduce_简单了解python filter、map、reduce的区别

python lambda map reduce_简单了解python filter、map、reduce的区别

这篇文章主要介绍了简单了解python filter、map、reduce的区别,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下python中有一些非常有趣的函数，面试的时候可能会遇到。今天也来总结一下，不…
阅读更多...
面试问题汇总 精选 分析 解答 职业规划 part 4

面试问题汇总 精选 分析 解答 职业规划 part 4

程序员做业余项目、记笔记和写博客的重要性【经典】 编程是一种创造过程，业余项目允许程序员在没有截止日期或各种限制的条件下，以探索形式编程。业余项目之所以重要，有以下几个原因。 探索新技术 每天都会不断有新技术出现，而…
阅读更多...
NB-IOT连接移动onenet平台流程

NB-IOT连接移动onenet平台流程

1. 先创建账号，然后创建产品 2. 创建设备，用ATCGSN和ATCIMI查询NB-IOT的IMEI和IMSI填写上去。 3. 创建好的设备。 转载于:https://www.cnblogs.com/429512065qhq/p/8359247.html
阅读更多...
sort,uniq,wc指令简单用法

sort,uniq,wc指令简单用法

sort用于排序，可以根据不同的数据类型来进行排序，例如想要查看最后一个登陆的用户信息，可以把last和sort结合起来使用，按照登陆时间排序。 使用sort排序： sort常用参数： -f ：忽略大小写的差异 -…
阅读更多...
java ejb jsp 架构_JavaEE架构

java ejb jsp 架构_JavaEE架构

B/S 体系结构image.pngJava EE 经典架构image.pngJava EE 13规范JDBCimage.pngJDBC 对象与接口java.sql.DriverManager：用于管理JDBC驱动的服务类，当JDBC驱动加载至内存后，DriverManager会自动注册JDBC驱动，然后通过getConnection…
阅读更多...
音视频中的CBR,VBR,ABR

音视频中的CBR,VBR,ABR

视频码率CBR和VBR 固定码率（CBR）与可变码率（VBR） 一般在我们输出视频文件的时候都会碰到一个选择即CBR与VBR，CBR的英文全称是Constant Bit Rate翻译过来是固定码率，就是说每一秒种的画面如果看做是一个…
阅读更多...
fifo java_java – 如何保证ThreadPoolExecutor中的FIFO执行顺序

fifo java_java – 如何保证ThreadPoolExecutor中的FIFO执行顺序

我用这行代码创建一个ThreadPoolExecutor：private ExecutorService executor new ThreadPoolExecutor(5, 10, 120, TimeUnit.SECONDS, new ArrayBlockingQueue(20, true));然后,我运行25个任务(T01到T25),所以情况是：>目前正在运行的5个任务(T01到T0…
阅读更多...
HihoCoder 1671 DFS

HihoCoder 1671 DFS

本以为是个简单的水题，好吧，其实就是个水题，虽然我还是…… 题意的理解上有一点小小的问题orz，这里的括号里的字母是可以看成一个整体的，可以看作一个字母来进行反转， 比如说，(abc(de))&#xf…
阅读更多...
avs 中国音视频标准DRA 中音频标准及应用

avs 中国音视频标准DRA 中音频标准及应用

DRA 是Digital Rise Audio的缩写。是广州广晟数码技术有限公司（Digital Rise Technology)开发的一项数字音频编码技术，目前是音频编码的国家标准。2007年1月被批准成为中国电子行业标准（标准号SJ/T11368-2006）。DRA音频标准可应用…
阅读更多...
UWP数据绑定

UWP数据绑定

已针对 Windows 10 上的 UWP 应用更新。 有关 Windows 8.x 文章，请参阅存档 ] 数据绑定是你的应用 UI 用来显示数据的一种方法，可以选择与该数据保持同步。 借助数据绑定，你可以将关注的数据从关注的 UI 中分离开来，从而可形成一个…
阅读更多...
资源链接

资源链接

http://cn.epubee.com/ 电子书 http://www.feemic.cn/mooc_search/1002384010 中国大学mooc视频下载 http://www.icourse163.org 中国大学mooc http://www.xuetangx.com 学堂在线 http://yun.java1234.com/ 视频搜索 http://www.52studyit.com/转载于:https://www.cnblogs.co…
阅读更多...
最大开源代码sourceforge 简介 及视音频方面常用的开源代码

最大开源代码sourceforge 简介 及视音频方面常用的开源代码

所有的音视频凯源代码在这里：http://sourceforge.net/directory/audio-video/os:windows/，你可以下载分析，视频不懂请发邮件给我，帮你分析。 0.视频项目 0.1 VLC media player VLC 多媒体播放器（最初为VideoLAN Clien…
阅读更多...
[转]被当做狗和鸡来驱赶的百姓

[转]被当做狗和鸡来驱赶的百姓

原文链接：知乎 杜甫写过许多好诗。 好诗，不一定是辞藻美、场面好、色色入画。 不一定是吴楚东南坼，乾坤日夜浮。不一定是五更鼓角声悲壮，三峡星河影动摇。 不一定是星垂平野阔，月涌大江流。不一定是细雨鱼儿出&#xf…
阅读更多...
背包问题（动态规划）

背包问题（动态规划）

本篇文章作为个人的背包问题学习资料，来自转载 dd大牛的《背包九讲》. P01: 01背包问题 题目 有N件物品和一个容量为V的背包。第i件物品的费用是c[i]，价值是w[i]。求解将哪些物品装入背包可使这些物品的费用总和不超过背包容量，且价值总和最大…
阅读更多...
最新文章

Copyright @ 2022~2023