ICE集群環境搭建

本文轉載自查看原文 2014-07-18 10:20 5596 ICE相關

本文將介紹ice搭建高可用集群環境的詳細操作步驟，實現 register 的主從備份、雙服務器節點負載均衡等功能

1、下載：

到官網 http://www.zeroc.com/ 下載最新的Ice-x.x.x.msi (windows)版本

2、安裝：

雙擊下載下來的安裝文件，安裝到自己喜歡的目錄下(例：D:\Program Files\ZeroC)

3、環境配置：

設置ICE的環境變量 ICEJ_HOME = D:\Program Files\ZeroC\ice-x.x.x

同時將 %ICEJ_HOME%\bin 目錄添加到 Path 路徑中

下邊介紹一個偽集群環境的配置和搭建步驟，節點情況如下：

主注冊節點(Master)：tcp -h 127.0.0.1 -p 4061

從注冊節點(Replica)：tcp -h 127.0.0.1 -p 4062

服務節點node1: tcp -p 5062

服務節點node2: tcp -p 5063

1、編寫主注冊節點 register_master.conf 配置文件

IceGrid.InstanceName=DemoGrid #設置注冊節點的實例名稱，其它的配置均基於該名字配置

IceGrid.Registry.Client.Endpoints=tcp -p 4061 #設置用於監聽客戶端連接的協議類型及端口
IceGrid.Registry.Data=D:\ice_service\register\data #設置主注冊節點的數據存儲目錄
IceGrid.Registry.Server.Endpoints=tcp #設置與服務器節點之間通訊的協議類型，不指定端口則由系統自動分配
IceGrid.Registry.Internal.Endpoints=tcp #
IceGrid.Registry.AdminPermissionsVerifier=DemoGrid/NullPermissionsVerifier #指定進入管理系統的安全驗證方式

IceGridAdmin.Username=test #設置管理用戶名
IceGridAdmin.Password=test #設置管理密碼

2、編寫從注冊節點 register_slave.conf 配置文件

Ice.Default.Locator=DemoGrid/Locator:tcp -h 127.0.0.1 -p 4061 #指定主注冊節點的位置

IceGrid.Registry.Client.Endpoints=tcp -p 4062 #設置用於監聽客戶端連接的協議類型及端口

IceGrid.Registry.Data=D:\ice_service\register\replica_data #設置主注冊節點的數據存儲目錄
IceGrid.Registry.Server.Endpoints=tcp #設置與服務器節點之間通訊的協議類型，不指定端口則由系統自動分配
IceGrid.Registry.Internal.Endpoints=tcp #
IceGrid.Registry.AdminPermissionsVerifier=DemoGrid/NullPermissionsVerifier #指定進入管理系統的安全驗證方式

IceGridAdmin.Username=test #設置管理用戶名
IceGridAdmin.Password=test #設置管理密碼

3、編寫服務節點 node1.conf 配置文件

Ice.Default.Locator=DemoGrid/Locator:tcp -h 127.0.0.1 -p 4061 #指定主注冊節點的位置

IceGrid.Node.Data=D:\ice_service\node\data #設置節點1相關數據的存儲目錄
IceGrid.Node.Endpoints=tcp -p 5062 #指定節點1用於監聽客戶端連接的端口號
IceGrid.Node.Name=MyNode1 #指定節點1的名稱

Ice.StdErr=D:\ice_service\node\logs\node.stderr.log #指定錯誤日志文件
Ice.StdOut=D:\ice_service\node\logs\node.stdout.log #指定標准輸出流日志文件

4、編寫服務節點 node2.conf 配置文件

Ice.Default.Locator=DemoGrid/Locator:tcp -h 127.0.0.1 -p 4061 #指定主注冊節點的位置

IceGrid.Node.Data=D:\ice_service\node\data2 #設置節點1相關數據的存儲目錄
IceGrid.Node.Endpoints=tcp -p 5063 #指定節點1用於監聽客戶端連接的端口號
IceGrid.Node.Name=MyNode2 #指定節點2的名稱

Ice.StdErr=D:\ice_service\node\logs\node2.stderr.log #指定錯誤日志文件
Ice.StdOut=D:\ice_service\node\logs\node2.stdout.log #指定標准輸出流日志文件

5、編寫IceBox.Service服務及相應的實現類

1）編寫slice配置文件，內容如下：

module com{

module mop{

module interf{

module generated{

interface CalcServiceIce{

double calc(double d1,double d2);

};

interface MessageServiceIce{

string sendMessage(string msg ); //string全為小寫

};

2）使用eclipse的slice2java插件將該配置文件生成相應的java源碼

3）編寫實現類 MessageServiceIceImpl 實現第二步生成的抽象類 _MessageServiceIceDisp ，代碼如下：

package com.mop.ice.serv;

import Ice.Current;

import com.mop.interf.generated._MessageServiceIceDisp;

public class MessageServiceIceImpl extends _MessageServiceIceDisp{

private static final long serialVersionUID = -6954195427744180145L;

     @Override

     public String sendMessage(String msg, Current __current) {

          System.out.println("recv:"+msg);

          return "msg handled success";

     }

}

4）編寫IceBox.Service服務類，用於將服務配置到icegrid中：

package com.mop.ice.icebox;

import com.mop.ice.serv.MessageServiceIceImpl;

import Ice.Communicator;

import IceBox.Service;

public class MessageServiceI extends Ice.ObjectImpl implements Service {

     /**

     *

     */

     private static final long serialVersionUID = 43338146304475187L;



     private Ice.ObjectAdapter _adapter;

     @Override

     public void start(String name, Communicator ci, String[] args) {

          _adapter=ci.createObjectAdapter(name);



          _adapter.add(new MessageServiceIceImpl(), Ice.Util.stringToIdentity("IceBoxTest"));

          _adapter.activate();

     }

     @Override

     public void stop() {

          if(_adapter!=null){

               _adapter.deactivate();

          }

     }

}

5）將上述生成的類和自己編寫的兩個類打包，並放到指定的lib目錄下

6、編寫xml配置文件 app.xml ，在icegrid中集成icebox服務

<?xml version="1.0" encoding="UTF-8"?>

<icegrid>

<application name="testIceBoxApp"> 

<replica-group id="testIceBoxReplicaGroup"> 

     <load-balancing type="adaptive" /> 

      <object identity="IceBoxTest"

               type="::com::mop::interf::generated::_MessageServiceIceDisp" />

</replica-group>

<node name="MyNode2"> 

    <icebox id="testIceBox"   

exe="C:\Program Files\Java\jdk1.7.0_09\bin\java.exe"> 

      <option>-server</option>

<option>-classpath</option>

  <option>-Djava.ext.dirs=D:\ice_service\lib</option>

 

<option>IceBox.Server</option> 

<log path="D:\ice_service\PassportAdminOut.log" property="Ice.StdOut"/>

      <log path="D:\ice_service\PassportAdminErr.log" property="Ice.StdErr"/>

<service name="testIceAdapter" entry="com.mop.ice.icebox.MessageServiceI">

         <adapter name="testIceAdapter" 

                    replica-group="testIceBoxReplicaGroup" 

                    />

     </service>



     </icebox>

     <icebox id="testIceBox1" exe="C:\Program Files\Java\jdk1.7.0_09\bin\java.exe">

<option>-server</option>

     <option>-classpath</option>

<option>-Djava.ext.dirs=D:\ice_service\lib</option>



     <option>IceBox.Server</option>

     <log path="D:\ice_service\PassportAdminOut.log" property="Ice.StdOut"/>

<log path="D:\ice_service\PassportAdminErr.log" property="Ice.StdErr"/>

     <service name="testIceAdapter1" entry="com.mop.ice.icebox.MessageServiceI">

         <adapter name="testIceAdapter1"

                    replica-group="testIceBoxReplicaGroup"

                    />

     </service>



     </icebox>

</node>

</application>

</icegrid>

7、啟動

> icegridregistry --Ice.Config=register_master.conf #啟動主注冊服務器

> icegridregistry --Ice.Config=register_slave.conf #啟動從注冊服務器

> icegridnode --Ice.Config=node1.conf #啟動服務器節點1

> icegridnode --Ice.Config=node2.conf #啟動服務器節點2

> icegridadmin -u test -p test --Ice.Default.Locator="IceGrid/Locator:tcp -p 4061:tcp -p 5061" -e "application add 'app.xml' "

8、編寫客戶端進行測試

使用eclipse編寫客戶端測試類Client，代碼結構如下：

public class Client {

public static void main(String[] args) {

int status = 0;

Communicator ic = null ;

try {

String str = String. format( "%s:%s -h %s -p %s:%s -h %s -p %s", "IceGrid/Locator",

"tcp" , "127.0.0.1" , "4061" ,

"tcp" , "127.0.0.1" , "4062" );

InitializationData localInitializationData = new InitializationData();

localInitializationData. properties = Util. createProperties();

localInitializationData. properties .setProperty(

"Ice.Default.Locator" , str);

ic = Util. initialize(localInitializationData);

MessageServiceIcePrx msgIceBoxclient = MessageServiceIcePrxHelper

. checkedCast(ic.stringToProxy( "IceBoxTest")); //此處IceBoxTest可以替換

//成IceBoxTest@testIceBoxReplicaGroup

System. out .println(msgIceBoxclient.sendMessage( "IceBox msg"));

} catch (Ice.LocalException e) {

e.printStackTrace();

status = 1;

} catch (Exception e) {

System. err .println(e.getMessage());

status = 1;

}

if (ic != null) {

try {

ic.destroy();

} catch (Exception e) {

System. err .println(e.getMessage());

status = 1;

}

System. exit(status);

}

擴展知識：

其實可以自己實現一個與icebox功能類似的server類，用以加載同樣的服務，同時修改配置文件app.xml 即可。

例：

保持上述其它操作不變，只需對如下兩步進行修改即可，具體操作如下：

1、編寫 IceService 類如下（上述的MessageServiceI 類就用不着了）：

package com.mop.ice;

import com.mop.ice.serv.CalcServiceIceImpl;

import com.mop.ice.serv.MessageServiceIceImpl;

import Ice.Communicator;

import Ice.ObjectImpl;

public class IceService {

     /**

     * @Description:

     *

     * @param args

     */

     public static void main(String[] args) {

          int status = 0;

          Communicator ic = null;



          try{

          ic=Ice.Util.initialize(args);

          Ice.ObjectAdapter adapter=ic

                    .createObjectAdapterWithEndpoints("testAdapter", "default -h *");



          ObjectImpl object1=new MessageServiceIceImpl();

          ObjectImpl object2=new CalcServiceIceImpl();



          adapter.add(object1, ic.stringToIdentity("messageService"));

          adapter.add(object2, ic.stringToIdentity("calcService"));



          adapter.activate();

          ic.waitForShutdown();

          }catch(Ice.LocalException le){

               le.printStackTrace();

               status=1;

          }catch(Exception e){

               e.printStackTrace();

               status=2;

          }

          if(ic!=null){

               try{

               ic.destroy();

               }catch(Exception e){

                    e.printStackTrace();

                    status=3;

               }

          }

          System.exit(status);

     }

}

2、將app.xml配置文件修改如下：


<?xml version="1.0" encoding="UTF-8" ?>

<icegrid>
<application name="testApp">
    <replica-group id="ReplicatedTestAdapter">
     <load-balancing type="adaptive" load-sample="1" n-replicas="1"/>
  <object identity="IceBoxTest"

               type="::com::mop::interf::generated::_MessageServiceIceDisp" />

     <object identity="calcService"
               type="::com::mop::ice::serv::CalcServiceIceImpl" />
     </replica-group>

     <server-template id="testServerTemplate">
      <parameter name="index"/>
     <parameter name="servClass"/>
     <parameter name="exepath" default="C:\Program Files\Java\jdk1.7.0_09\bin\java"/>
     <server id="testServer${index}"
               exe="${exepath}"
               activation="on-demand">
         <option>-server</option>
          <option>-classpath</option>
          <option>C:\Program Files\ZeroC\Ice-3.4.1\bin</option>
          <option>-Djava.ext.dirs=D:\ice_service\lib</option>
         <option>${servClass}</option>


          <adapter name="testAdapter"
replica-group="ReplicatedTestAdapter"
endpoints="tcp"/>

     </server>
     </server-template>

     <node name="MyNode1">
      <server-instance template="testServerTemplate"
index="1"
servClass="com.mop.ice.IceService"/>
     </node>


</application>
</icegrid>

3、將第一步寫好的IceService 類隨同前一部分的內容重新打包，並放到指定的lib目錄中

4、執行命令：

> icegridadmin -u test -p test --Ice.Default.Locator="IceGrid/Locator:tcp -p 4061:tcp -p 5061" -e "application update 'app.xml' "

5、使用前一部分編寫好的客戶端進行測試，即可成功！

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 ICE分布式文件管理系統——ICE環境搭建（其二） druid 搭建集群環境 Spark 集群環境搭建 redis集群環境搭建 eureka集群環境搭建 Mysql 集群環境搭建 DockerSwarm 集群環境搭建 hadoop集群環境搭建 Redis集群環境搭建 cassandra集群環境搭建