Test d'installation du cluster metaq

1,ZooKeeperClusterInstallation,Peut être référencé ZooKeeperClusterPratiques de construction environnementale http://www.linuxidc.com/Linux/2013-04/83562.htm

2,Téléchargerhttps://github.com/killme2008/Metamorphosis/tree/metamorphosis-all-1.4.6.2,Si vous ne voulez pas compiler vous - même, vous pouvez le télécharger directementhttp://fnil.net/downloads/index.html,J'ai choisi de compiler moi - même ici,Principalement plus tard, s'il y a un problème, vous pouvez modifier son code source,Recompiler

3,mavenCompiler,mavenL'environnement recherche lui - même configuré,TéléchargerallAprès le projet, vous devez compiler ses sous - projetsmetamorphosis-server-wrapper.dosL'environnement entre dans son répertoiremvn eclipse:eclipse,Importer àeclipse,AvececlipseCompilation du plug - in.Ou directementdosExécuter dans ce répertoiremvn clean install -Dmaven.test.skip=true.Une fois terminétarget Produit dans le catalogue jarSac;

Peut être créé dans le projet libDossiers,Saisissez la commande suivante：mvn dependency:copy-dependencies -DoutputDirectory=lib （Non.DoutputDirectoryLa sortie par défaut verstarged/dependencyEn bas.）.EncoreinstallDejarBaotou!copyÀlibEn bas..

4, Télécharger sur Serveur

Modifications nécessairesconf/server.iniDocumentation

[system]brokerId=2

numPartitions=1

serverPort=8123

ashboardHttpPort=8120

unflushThreshold=0

unflushInterval=10000

maxSegmentSize=1073741824

maxTransferSize=1048576

deletePolicy=delete,168

deleteWhen=0 0 6,18 * * ?

flushTxLogAtCommit=1

stat=true

dataPath=/data1/metaq/data

dataLogPath=/data1/metaq/log

[zookeeper]

zk.zkConnect=192.168.1.1:2181,192.168.1.2:2181,192.168.1.3:2181

zk.zkSessionTimeoutMs=30000

zk.zkConnectionTimeoutMs=30000

zk.zkSyncTimeMs=5000

;; Topics section

[topic=test]

[topic=meta-test]

Cluster Si vous avez besoin de modifier la partie rouge ci - dessus ,brokerIdChaqueServeur Ce n'est pas pareil sur les noeuds

dataPath,dataLogPath Si vous le faites vous - même , Besoin de chaque Serveurmkdir

Distribuer aux noeuds , À chaque noeud bin .Tout ce qui suit est exécuté metaServer.sh start

Exécuter lorsque l'arrêt est nécessaire metaServer.sh stop

Voir l'étatsh metaServer.sh status

5,Exemples d'application

package com.test.metaq;

import Java.util.concurrent.Executor;

import com.taobao.metamorphosis.Message; import com.taobao.metamorphosis.client.MessageSessionFactory; import com.taobao.metamorphosis.client.MetaClientConfig; import com.taobao.metamorphosis.client.MetaMessageSessionFactory; import com.taobao.metamorphosis.client.consumer.ConsumerConfig; import com.taobao.metamorphosis.client.consumer.MessageConsumer; import com.taobao.metamorphosis.client.consumer.MessageListener; import com.taobao.metamorphosis.exception.MetaClientException; import com.taobao.metamorphosis.utils.ZkUtils.ZKConfig;

public class AsyncConsum {

 public static void main(String[] args) {   final MetaClientConfig metaClientConfig = new MetaClientConfig();          final ZKConfig zkConfig = new ZKConfig();          zkConfig.zkConnect = "10.168.140.48:2181";          metaClientConfig.setZkConfig(zkConfig);          MessageSessionFactory sessionFactory = null;   try {   sessionFactory = new MetaMessageSessionFactory(metaClientConfig);   } catch (MetaClientException e) {   // TODO Auto-generated catch block   e.printStackTrace();   }          final String topic = "test";          final String group = "meta-example";          MessageConsumer consumer = sessionFactory.createConsumer(new ConsumerConfig(group));          try {   consumer.subscribe(topic, 1024 * 1024, new MessageListener() {        public void recieveMessages(Message message) {            System.out.println("Receive message " + new String(message.getData()));        }        public Executor getExecutor() {            return null;        }    });   consumer.completeSubscribe();   } catch (MetaClientException e) {   // TODO Auto-generated catch block   e.printStackTrace();   }   }

}

package com.test.metaq;

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader;

import com.taobao.metamorphosis.Message; import com.taobao.metamorphosis.client.MessageSessionFactory; import com.taobao.metamorphosis.client.MetaClientConfig; import com.taobao.metamorphosis.client.MetaMessageSessionFactory; import com.taobao.metamorphosis.client.producer.MessageProducer; import com.taobao.metamorphosis.client.producer.SendResult; import com.taobao.metamorphosis.exception.MetaClientException; import com.taobao.metamorphosis.utils.ZkUtils.ZKConfig;

public class Products {

 public static void main(String[] args) {   final MetaClientConfig metaClientConfig = new MetaClientConfig();   final ZKConfig zkConfig = new ZKConfig();   zkConfig.zkConnect = "10.168.140.48:2181";   metaClientConfig.setZkConfig(zkConfig);   MessageSessionFactory sessionFactory = null;   try {   sessionFactory = new MetaMessageSessionFactory(metaClientConfig);   } catch (MetaClientException e) {   e.printStackTrace();   }   MessageProducer producer = sessionFactory.createProducer();   final String topic = "test";   producer.publish(topic);   BufferedReader reader = new BufferedReader(new InputStreamReader(     System.in));   String line = "qiujinyong";   try {   while ((line = reader.readLine()) != null) {     SendResult sendResult = producer.sendMessage(new Message(topic,       line.getBytes()));     if (!sendResult.isSuccess()) {     System.err.println("Send message failed,error message:"       + sendResult.getErrorMessage());     } else {     System.out.println("Send message successfully,sent to "       + sendResult.getPartition());     }   }   } catch (IOException e) {   // TODO Auto-generated catch block   e.printStackTrace();   } catch (MetaClientException e) {   // TODO Auto-generated catch block   e.printStackTrace();   } catch (InterruptedException e) {   // TODO Auto-generated catch block   e.printStackTrace();   }

 }

}

Emballeztest.jarAprès,PasseServeurAllez. java -cp test.jar com.test.metaq.Products Entrée en ligne de commandemessage

Emballeztest.jarAprès,PasseServeurAllez. java -cp test.jar com.test.metaq.AsyncConsum La ligne de commande recevra message