文档章节

dubbo 初始操作。简单理解1

明瞐
 明瞐
发布于 2018/09/04 15:46
字数 726
阅读 26
收藏 3

目前来说 分布式系统已经十分普遍,国内常用的架构通常为两种,dubbo与springCloud。虽然两种小弟都在本地耍过,可没有实际经验,基本还停留在纸上谈兵的阶段。

如今公司使用了dubbo,特意做些笔录:

以下是我的个人理解:

dubbo项目,在项目结构上,与传统的垂直分层项目基本一致。非要直观的说不同之处,那就是在最外层有一个pom.xml文件,如图

目前,dubbo项目又开始维护,并转移到了阿帕奇官网。只要项目结构不是特别奇葩,小弟用idea直接加载该pom文件 就可以导入所有的分支项目(因为该pom是父项目的)。

另:idea 已经集成了dubbo插件,下载安装后,可直接创建dubbo项目,与springCloud相比也不麻烦了。

因,公司再git仓库中没有properties文件,小弟我找了一圈的人去copy该文件,然后导入项目中,真是欲仙欲死。还好公司项目中规中矩。导入后没费什么劲就起来了。

启动没有使用tomcat 也没使用spring加载,而是dubbo官方推荐的main方法:

进入源码可发现:

/*
 * Copyright 1999-2011 Alibaba Group.
 *  
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *  
 *      http://www.apache.org/licenses/LICENSE-2.0
 *  
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.alibaba.dubbo.container;

import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Date;
import java.util.List;

import com.alibaba.dubbo.common.Constants;
import com.alibaba.dubbo.common.extension.ExtensionLoader;
import com.alibaba.dubbo.common.logger.Logger;
import com.alibaba.dubbo.common.logger.LoggerFactory;
import com.alibaba.dubbo.common.utils.ConfigUtils;

/**
 * Main. (API, Static, ThreadSafe)
 * 
 * @author william.liangf
 */
public class Main {

    public static final String CONTAINER_KEY = "dubbo.container";

    public static final String SHUTDOWN_HOOK_KEY = "dubbo.shutdown.hook";
    
    private static final Logger logger = LoggerFactory.getLogger(Main.class);

    private static final ExtensionLoader<Container> loader = ExtensionLoader.getExtensionLoader(Container.class);
    
    private static volatile boolean running = true;

    public static void main(String[] args) {
        try {
            if (args == null || args.length == 0) {
                String config = ConfigUtils.getProperty(CONTAINER_KEY, loader.getDefaultExtensionName());
                args = Constants.COMMA_SPLIT_PATTERN.split(config);
            }
            
            final List<Container> containers = new ArrayList<Container>();
            for (int i = 0; i < args.length; i ++) {
                containers.add(loader.getExtension(args[i]));
            }
            logger.info("Use container type(" + Arrays.toString(args) + ") to run dubbo serivce.");
            
            if ("true".equals(System.getProperty(SHUTDOWN_HOOK_KEY))) {
	            Runtime.getRuntime().addShutdownHook(new Thread() {
	                public void run() {
	                    for (Container container : containers) {
	                        try {
	                            container.stop();
	                            logger.info("Dubbo " + container.getClass().getSimpleName() + " stopped!");
	                        } catch (Throwable t) {
	                            logger.error(t.getMessage(), t);
	                        }
	                        synchronized (Main.class) {
	                            running = false;
	                            Main.class.notify();
	                        }
	                    }
	                }
	            });
            }
            
            for (Container container : containers) {
                container.start();
                logger.info("Dubbo " + container.getClass().getSimpleName() + " started!");
            }
            System.out.println(new SimpleDateFormat("[yyyy-MM-dd HH:mm:ss]").format(new Date()) + " Dubbo service server started!");
        } catch (RuntimeException e) {
            e.printStackTrace();
            logger.error(e.getMessage(), e);
            System.exit(1);
        }
        synchronized (Main.class) {
            while (running) {
                try {
                    Main.class.wait();
                } catch (Throwable e) {
                }
            }
        }
    }
    
}

以上,加载spring时,也就会加载dubbo配置的xml文件,从而使用指定的dubbo命名空间加载dubbo对象。

© 著作权归作者所有

明瞐
粉丝 8
博文 107
码字总数 40377
作品 0
海淀
程序员
私信 提问
Dubbo编码解码

前两章中讲到了Dubbo的服务启动以及服务引用过程,之后的篇章开始讲解一下Dubbo的其他模块,开始在在来的基础上讲一下细节的内容。本章主要讲解Dubbo的编码解码内容。 编码(encode):我们可...

档滴啷当
2017/12/20
0
0
Spring+Dubbo+Zookeeper简单框架与使用

例子参考地址:http://www.cnblogs.com/Javame/p/3632473.html 一、实例搭建 1、搭建框架前先下载Zookeeper(http://mirrors.cnnic.cn/apache/zookeeper/zookeeper-3.3.6/zookeeper-3.3.6.ta......

阿阿阿阿阿局
2016/09/25
1K
1
分布式服务-DUBBOX(七):重试、超时

1、dubbo重试与超时 1)默认dubbo重试3次,超时时间为1秒。 2)测试过程中发现,注解com.alibaba.dubbo.config.annotation.Service(retries默认值为0,即不重试)retries=0不生效,不知是哪...

warlockssss
2016/12/02
996
0
dubbo源码理解(1)启动初始化与bean加载

今天看了一些博文,都是关于dubbo源码解析方面的。觉得有必要记一下。 问题1:spring 如何注入dubbo 的?或者说怎么集成dubbo 的,或者说 dubbo启动时怎么启动spring的? 1、首先想要实现 在...

明瞐
2018/10/13
180
0
RPC-非阻塞通信下的同步API实现原理,以Dubbo为例

Netty在Java NIO领域基本算是独占鳌头,涉及到高性能网络通信,基本都会以Netty为底层通信框架,Dubbo 也不例外。以下将以Dubbo实现为例介绍其是如何在NIO非阻塞通信基础上实现同步通信的。 ...

echov
2018/01/14
2.4K
0

没有更多内容

加载失败,请刷新页面

加载更多

JS--function

一、声明提前(hoist) 在js程序开始执行前,引擎会查找所有var声明的变量和function声明的函数,集中到当前作用域顶部集中创建,赋值留在原地 二、三种创建函数的方式 1、声明方式创建函数-...

wytao1995
今天
4
0
微服务之间调用控制器注解类型的差异

今天在一个业务服务通过Feign调用文件服务上传文件时遇到了几个问题: 1. 提示http请求头过大的问题; 此时需要修改bootstrap.yml,加入 server: max-http-header-size: 10000000 用以放大...

不再熬夜
今天
6
0
用 4G 工作是什么体验

七月开始,因为工作原因,在公司附近租了个住处,方便工作。离公司近了,感觉就是不一样,之前每天 5:30 就要起床赶地铁,现在可以睡到自然醒,一看才 7 点,悠闲的起床洗漱,踱步到公司,都...

zzxworld
今天
6
0
sonar报错volatile

问题发生 原先代码如下: //认证授权码private static volatile String AUTHORIZATION_CODE = "init"; git push 之后,sonar认为这是个bug检测报告截图如下: 分析排查 解释说明: Markin...

开源小菜鸟2333
今天
5
0
《Java实践指南》--读后

闲读《Java实践指南》... 1.lvy 某些项目中能够看到ivy.xml。早期使用ant的项目中,常常用ivy.xml来下载项目依赖。 2.ant 作为java程序员,应该都知道ant,虽然可能用过的人不多。为什么ant...

RippleChan
今天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部