dubbo 初始操做。簡單理解1

目前來講 分佈式系統已經十分廣泛,國內經常使用的架構一般爲兩種,dubbo與springCloud。雖然兩種小弟都在本地耍過,可沒有實際經驗,基本還停留在紙上談兵的階段。java

現在公司使用了dubbo,特地作些筆錄:git

如下是個人我的理解:spring

dubbo項目,在項目結構上,與傳統的垂直分層項目基本一致。非要直觀的說不一樣之處,那就是在最外層有一個pom.xml文件,如圖express

目前,dubbo項目又開始維護,並轉移到了阿帕奇官網。只要項目結構不是特別奇葩,小弟用idea直接加載該pom文件 就能夠導入全部的分支項目(由於該pom是父項目的)。apache

另:idea 已經集成了dubbo插件,下載安裝後,可直接建立dubbo項目,與springCloud相比也不麻煩了。tomcat

因,公司再git倉庫中沒有properties文件,小弟我找了一圈的人去copy該文件,而後導入項目中,真是欲仙欲死。還好公司項目中規中矩。導入後沒費什麼勁就起來了。架構

啓動沒有使用tomcat 也沒使用spring加載,而是dubbo官方推薦的main方法:app

進入源碼可發現:less

/*
 * 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對象。分佈式

相關文章
相關標籤/搜索