UncodeMQ使用文档

说明：目前只在部分项目中使用，欢迎学习交流。

说明：集群由多个Group组成一个队列，每个Group由Master和Salve两个Broker组成，整体无中心架构。

2配置信息

4目录

umq/conf配置umq/data数据存储umq/logs日志umq/lib依赖jar

生产者为单例，必须最少执行一次connect操作，连接成功后不会重复connect。

Stringcfg="file:/gitlib/uncode-mq/conf/config.properties";Producer.getInstance().connect(cfg);for(inti=0;i<10000;i++){Listlist=newArrayList();Topictopic=newTopic();topic.setTopic("umq");topic.addContent("umq作者juny=>"+i);list.add(topic);Producer.getInstance().send(list);}或Propertiesconfig=newProperties();config.setProperty("mq.port","9000");config.setProperty("mq.zk.connect","192.168.1.14:2181");config.setProperty("mq.enable.zookeeper","true");ServerConfigserverConfig=newServerConfig(config);Producer.getInstance().connect(serverConfig);for(inti=0;i<10000;i++){Listlist=newArrayList();Topictopic=newTopic();topic.setTopic("umq");topic.addContent("umq作者juny=>"+i);list.add(topic);Producer.getInstance().send(list);}消费者1普通方式

Stringcfg="file:/gitlib/uncode-mq/conf/config.properties";Consumer.runningConsumerRunnable(cfg);Consumer.addSubscriber(newConsumerSubscriber(){//订阅主题@OverridepublicListsubscribeToTopic(){Listtps=newArrayList();tps.add("umq");returntps;}//通知@Overridepublicvoidnotify(Topictopic){System.err.println("consumersubscriber:"+topic.toString());}});