IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 网络协议 -> Dubbo -> 正文阅读

[网络协议]Dubbo

目录

一、什么是分布式

二、软件架构演进过程? ??

? ? ? ? ?1.1 单体架构

1.2 垂直架构

1.3 SOA架构

1.4 微服务架构

三、什么是RPC

四、Dubbo

4.1 基本概念

?4.2 Dubbo环境搭建

4.2.1 Zookeeper

?4.2.2?在windows环境中安装zookeeper

4.2.3 windows下面安装dubbo-admin

4.2.4 编写服务方和消费方

4.2.5 接口工程


一、什么是分布式

????????分布式系统是由一组通过网络进行通信、为了完成共同的任务而协调工作的计算机节点组成的系统。其目的是利用更多的机器,处理更多的数据。是建立在网络之上的系统????

二、软件架构演进过程? ??

1.1 单体架构

?架构说明:

全部功能集中在一个项目内(All in one)。

架构优点:

架构简单,前期开发成本低、开发周期短,适合小型项目。

架构缺点:

全部功能集成在一个工程中,对于大型项目不易开发、扩展和维护。

技术栈受限,只能使用一种语言开发。

系统性能扩展只能通过扩展集群节点,成本高。

1.2 垂直架构

?架构说明:

按照业务进行切割,形成小的单体项目。

架构优点:

技术栈可扩展(不同的系统可以用不同的编程语言编写)。

架构缺点:

功能集中在一个项目中,不利于开发、扩展、维护。

系统扩张只能通过集群的方式。

项目之间功能冗余、数据冗余、耦合性强。各项目之间可能产生相同的功能

1.3 SOA架构

SOA全称为Service-Oriented Architecture,即面向服务的架构。它可以根据需求通过网络对松散耦合的粗粒度应用组件(服务)进行分布式部署、组合和使用。一个服务通常以独立的形式存在于操作系统进程中。

站在功能的角度,把业务逻辑抽象成可复用的服务,通过服务的编排实现业务的快速再生

目的:把原先固有的业务功能转变为通用的业务服务,实现业务逻辑的快速复用。

架构说明:

将重复功能或模块抽取成组件的形式,对外提供服务,在项目与服务之间使用ESB(企业服务总线)的形式作为通信的桥梁。 这里的ESB理解为注册中心

架构优点:

重复功能或模块抽取为服务,提高开发效率。

可重用性高。

可维护性高。

架构缺点:

各系统之间业务不同,很难确认功能或模块是重复的。

抽取服务的粒度大。

系统和服务之间耦合度高。

1.4 微服务架构

?架构说明:

将系统服务层完全独立出来,抽取为一个一个的微服务。

抽取的粒度更细,遵循单一原则。

采用轻量级框架协议传输。

架构优点:

服务拆分粒度更细,有利于提高开发效率。

可以针对不同服务制定对应的优化方案。

适用于互联网时代,产品迭代周期更短。

架构缺点:

粒度太细导致服务太多,维护成本高。

分布式系统开发的技术成本高,对团队的挑战大。

三、什么是RPC

什么是RPC?

RPC全称为remote procedure call,即远程过程调用,?是一种进程间通信方式。比如两台服务器A和B,A服务器上部署一个应用,B服务器上部署一个应用,A服务器上的应用想调用B服务器上的应用提供的方法,由于两个应用不在一个内存空间,不能直接调用,所以需要通过网络来表达调用的语义和传达调用的数据。

需要注意的是RPC并不是一个具体的技术,而是指整个网络远程调用过程,是一种思想。

RPC是一个泛化的概念,严格来说一切远程过程调用手段都属于RPC范畴。各种开发语言都有自己的RPC框架。Java中的RPC框架比较多,广泛使用的有RMI、Hessian、Dubbo等。

四、Dubbo

4.1 基本概念

????????一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。?

节点角色名称
Provider暴露服务的服务提供方,在服务中心进行注册
Consumer调用远程服务的服务消费方,订阅服务注册中心的服务
Registry服务注册与发现的注册中心
Monitor统计服务的调用次数和调用时间的监控中心
Container服务运行容器

?4.2 Dubbo环境搭建

4.2.1 Zookeeper

????????Zookeeper 是 Apache Hadoop 的子项目,是一个树型的目录服务,支持变更推送,适合作为 Dubbo 服务的注册中心

zookeeper的目录结构:

流程说明:

  • 服务提供者(Provider)启动时: 向 /dubbo/com.foo.BarService/providers 目录下写入自己的 URL 地址

  • 服务消费者(Consumer)启动时: 订阅 /dubbo/com.foo.BarService/providers 目录下的提供者 URL 地址。并向 /dubbo/com.foo.BarService/consumers 目录下写入自己的 URL 地址

  • 监控中心(Monitor)启动时: 订阅 /dubbo/com.foo.BarService 目录下的所有提供者和消费者 URL 地址

?4.2.2?在windows环境中安装zookeeper

1.?下载地址:Index of /dist/zookeeper

2.??将conf文件夹下面的zoo_sample.cfg复制一份改名为zoo.cfg。

3. 在zookeeper目录下创建:

?修改zoo.fcg文件

dataDir=../data
dataLogDir=../log

clientPort=2181 ? zookeeper的端口号

4.启动bin目录下:zkServer.cmd , zkClient

启动成功后,Client窗口会显示:

可能遇到问题:闪退?

解决方案:编辑zkServer.cmd文件末尾添加pause 。这样运行出错就不会退出,会提示错误信息,方便找到原因。

4.2.3 windows下面安装dubbo-admin

????????dubbo本身并不是一个服务软件。它其实就是一个jar包,能够帮你的java程序连接到zookeeper,并利用zookeeper消费、提供服务。

????????开发时,需要监视Zookeeper注册中心都注册了哪些服务,有哪些消费者来消费这些服务。我们可以通过部署一个管理中心来实现,官方提供了一个可视化的监控程序dubbo-admin。其实管理中心就是一个web应用,部署到tomcat即可。

??详细安装可以看这个连接:新版本 Dubbo-admin 安装_Future_LL的博客-CSDN博客_dubboadmin安装

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

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

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

dubbo.registry.address=zookeeper://127.0.0.1:2181 dubbo.admin.root.password=root dubbo.admin.guest.password=guest

(4)重启tomcat

? ?(5)?访问http://localhost:8080/dubbo-admin-2.6.0/,输入用户名(root)和密码(root)

4.2.4 编写服务方和消费方

1. 服务提供者?

导入依赖:

<dependencies>
    <dependency>
      <groupId>org.springframework</groupId>
      <artifactId>spring-webmvc</artifactId>
      <version>${spring.version}</version>
    </dependency>

    <!-- dubbo相关 -->
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>dubbo</artifactId>
      <version>2.6.0</version>
    </dependency>
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.7</version>
    </dependency>
    <dependency>
      <groupId>com.github.sgroschupf</groupId>
      <artifactId>zkclient</artifactId>
      <version>0.1</version>
    </dependency>
    <dependency>
      <groupId>com.alibaba</groupId>
      <artifactId>fastjson</artifactId>
      <version>1.2.47</version>
    </dependency>
  </dependencies>
  <build>
    <plugins>
      <plugin>
        <groupId>org.apache.maven.plugins</groupId>
        <artifactId>maven-compiler-plugin</artifactId>
        <version>2.3.2</version>
        <configuration>
          <source>1.8</source>
          <target>1.8</target>
        </configuration>
      </plugin>
      <plugin>
        <groupId>org.apache.tomcat.maven</groupId>
        <artifactId>tomcat7-maven-plugin</artifactId>
        <configuration>
          <!-- 指定端口 -->
          <port>8082</port>
          <!-- 请求路径 -->
          <path>/</path>
        </configuration>
      </plugin>
    </plugins>
  </build>

插件部分使用了内置的tomcat, 可以忽略,自己配置

service接口:

public interface HelloService {
    String sayHello(String name);
}

service实现类:

import com.alibaba.dubbo.config.annotation.Service;
import com.righteye.service.HelloService;

@Service
public class HelloServiceImpl implements HelloService {
    public String sayHello(String name) {
        return "hello " + name;
    }
}

这里的@Service是dubbo提供的,添加这个注解表示这个服务被暴露出去

web.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         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_4_0.xsd"
         version="4.0">
    <context-param>
        <param-name>contextConfigLocation</param-name>
        <param-value>classpath:applicationContext*.xml</param-value>
    </context-param>
    <listener>
        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
    </listener>
</web-app>

applicationContext_provider.xml (dubbo配置文件)

<!-- 当前应用名称,用于注册中心计算应用间依赖关系,注意:消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbodemo_provider" />
    <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- 注册  协议和port   端口默认是20880 -->
    <dubbo:protocol name="dubbo" port="20880"></dubbo:protocol>
    <!-- 扫描指定包,加入@Service注解的类会被发布为服务  -->
    <dubbo:annotation package="com.righteye.service.impl" />

启动内置tomcat, tomacat run

观察dubbo-admin:

?这里一定要启动zookeeper的服务端,以及dubbo-admin !!!!, 昨天试了一晚上,zookeeper的服务端我没启动,查看不到服务,然后provider也不知道为啥访问不了,想砸电脑的心都有,反正就特sb, 低谷了 (QAQ)

如果各位大大有其他这个问题真正错误的原因,希望多多指正,孩子真的快哭了

2.服务消费者

导入依赖和提供者相同,如果使用内置tomcat,改下端口号

由于没有使用接口工程,所以在消费者中也创建了和提供者目录结构相同的service接口

?controller层:

package com.righteye.controller;

import com.alibaba.dubbo.config.annotation.Reference;
import com.righteye.service.HelloService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
public class UserController {
    @Reference
    private HelloService helloServiceImpl;

    @RequestMapping("/test")
    @ResponseBody
    public String getName(String name){
        System.out.println(name);
        //远程调用
        String result = helloServiceImpl.sayHello(name);
        System.out.println(result);
        return result;
    }
}

?@Reference 是dubbo中的注解,注入的功能

web.xml配置

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
         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_4_0.xsd"
         version="4.0">
    <servlet>
        <servlet-name>springmvc</servlet-name>
        <servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
        <!-- 指定加载的配置文件 ,通过参数contextConfigLocation加载 -->
        <init-param>
            <param-name>contextConfigLocation</param-name>
            <param-value>classpath:applicationContext-web.xml</param-value>
        </init-param>
        <load-on-startup>1</load-on-startup>
    </servlet>
    <servlet-mapping>
        <servlet-name>springmvc</servlet-name>
        <url-pattern>/</url-pattern>
    </servlet-mapping>
</web-app>

applicationContext-web.xml(dubbo配置文件)?

<!-- 当前应用名称,用于注册中心计算应用间依赖关系,注意:消费者和提供者应用名不要一样 -->
    <dubbo:application name="dubbo_consumer" />
    <!-- 连接服务注册中心zookeeper ip为zookeeper所在服务器的ip地址-->
    <dubbo:registry address="zookeeper://127.0.0.1:2181"/>
    <!-- 扫描的方式暴露接口  -->
    <dubbo:annotation package="com.righteye.controller" />

这里的dubbo:annotation加入后似乎自动就扫描了@Controller, 不需要加入组件扫描器;之前报错以为是Controller没有容器管理,目前删了也可以正常访问

启动消费者的tomcat

?

?不争气的眼泪似乎要流落下来。。。。因为没启动弄了好长时间

4.2.5 接口工程

????????上面的消费者中引入了service,但是这只为了不让程序报错;当服务增多的时候,service接口在消费者和提供者中就很冗余;所以可以使用接口工程,将service接口单独抽离出来

? ? ? 将接口工程打包,在消费者和提供者中导入依赖:

 <!--接口工程-->
    <dependency>
      <groupId>com.righteye</groupId>
      <artifactId>ch04_zk_interface</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>

??

  网络协议 最新文章
使用Easyswoole 搭建简单的Websoket服务
常见的数据通信方式有哪些?
Openssl 1024bit RSA算法---公私钥获取和处
HTTPS协议的密钥交换流程
《小白WEB安全入门》03. 漏洞篇
HttpRunner4.x 安装与使用
2021-07-04
手写RPC学习笔记
K8S高可用版本部署
mySQL计算IP地址范围
上一篇文章      下一篇文章      查看所有文章
加:2022-02-24 15:41:42  更:2022-02-24 15:43:27 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/26 8:55:05-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码