分布式开发-Zooker+dubbo入门-Demo-知了堂

分布式开发-Zooker+dubbo入门-Demo

知了小姐姐2019-12-23744

1.什么是SOA架构

SOA 是Service-Oriented Architecture的首字母简称，它是一个面向服务的架构模式（俗称：分布式；面服务的分布式）

为什么互联网项目会采用SOA架构呢？随着互联网的发展，网站应用的规模不断扩大，常规的垂直应用架构已无法应对，分布式服务架构以及流动计算架构势在必行。

2.Dubbo框架

Dubbo是一个分布式框架，由阿里巴巴团队开发的开源项目，在电商系统（高可用，高并发，高扩展）广泛的用用

Dubbo也是RPC远程服务调用一套解决方案，以及SOA服务治理方案

3.Dubbo框架原理

节点角色说明：

· Provider: 暴露服务的服务提供方。

· Consumer: 调用远程服务的服务消费方。

· Registry: 服务注册与发现的注册中心。

· Monitor: 统计服务的调用次调和调用时间的监控中心。

· Container: 服务运行容器。

调用关系说明：

· 0. 服务容器负责启动，加载，运行服务提供者。

· 1. 服务提供者在启动时，向注册中心注册自己提供的服务。

· 2. 服务消费者在启动时，向注册中心订阅自己所需的服务。

· 3. 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推

送变更数据给消费者。

· 4. 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，

如果调用失败，再选另一台调用。

· 5. 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计

数据到监控中心。

4.zookeeper + dubbo 的入门demo

思路：

（1）根据dubbo的原理图，案例中涉及到两个服务：服务提供者；服务消费者

（2）技术栈：spring+dubbo+zookeeper

（3）服务提供者：service层提供

（4）服务消费者：controller层提供

（5）但是两个程序不在同一个web服务器上，我们会设置两个服务端口8081；8082

（6）zookeeper就是我们服务的注册中心

服务提供者编码

（1）创建maven工程，在pom.xml中引入依赖，同时打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）编写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.xsd
            http://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）创建UserService

package com.zlt.service;

public interface UserService {
    public String getName();
}

（5）创建UserServiceImpl，添加@Service注解，但是@Service注解来自dubbo包

package com.zlt.service.impl;

import com.alibaba.dubbo.config.annotation.Service;
import com.zlt.service.UserService;

@Service
public class UserServiceImpl implements UserService {

    @Override
    public String getName() {
        return "zhiliaotang...";
    }

}

（6）通过maven来运行项目工程

命令：tomcat7:run，此命令是一个maven命令。如果第一次加入tomcat7-maven-plugin，需要在运行此命令的时候进行插件的下载

（7）tomcat7-maven-plugin插件命令【扩展】

tomcat7:run，启动嵌入tomcat，并运行当前项目

tomcat7:deploy，部署一个web war包

tomcat7:reload，重新加载web war包

tomcat7:start，启动tomcat

tomcat7:stop，停止tomcat

tomcat7:undeploy，停止一个web war包

服务消费方编码

（1）继续创建maven-webapp工程，pom.xml代码和前面的一样

（2）创建spring-mvc.xml配置文件

（3）在web.xml文件，加载spring-mvc.xml配置文件，并设置好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）拷贝业务接口到dubbocustomer项目工程里面

（4）创建IndexController，同时依赖UserService接口。注意：这里通过阿里的@Reference注解完成依赖关系

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 {

    @Reference
    private UserService userService; // 依赖注入UserService

    @RequestMapping("/index")
    @ResponseBody
    public 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.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">

    <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）测试，http://localhost:8082/index，通过8082的端口中index接口去访问8081端口中的service。

知了堂学习资源汇总，以后再也不用去百度了

2018-2019年网络安全行业深度报告(一)