zubs是一个消息队列;; ZBUS = MQ + RPC + PROXY 支持消息队列, 发布订阅, RPC, 代理(TCP/HTTP/DMZ)
消费者
ZConsumer.java
package com.gbcom.frame.zbus;
import java.io.IOException;
import org.zbus.broker.Broker;
import org.zbus.broker.ZbusBroker;
import org.zbus.mq.Consumer;
import org.zbus.mq.Consumer.ConsumerHandler;
import org.zbus.mq.server.MqServer;
import org.zbus.mq.server.MqServerConfig;
import org.zbus.net.http.Message;
/**
* 消费者:嵌入zbus服务器,订阅消息处理器
* @author SYZ
* @date 2016-6-14 下午02:58:50
* @version 1.0.0
* @see com.gbcom.frame.zbus.ZConsumer
*/
public class ZConsumer {
/** : (ZConsumer.main)
* @param args
* @throws Exception
*/
public static void main(String[] args) throws Exception {
try {
start();
} catch (IOException e) {
e.printStackTrace();
}
}
private static void start() throws Exception{
//嵌入zbus消息服务器。
MqServerConfig config = new MqServerConfig();
config.serverPort = 15555;
config.storePath = "./store";
final MqServer server = new MqServer(config);
server.start();
Broker broker = new ZbusBroker("127.0.0.1:15555"); //SingleBroker
Consumer consumer = new Consumer(broker, "MyMQ");
consumer.start(new ConsumerHandler() {
@Override
public void handle(Message msg, Consumer consumer) throws IOException {
//消息回调处理
System.out.println(msg);
}
});
}
}
生产者
ZProduct.java
package com.gbcom.frame.zbus;
import java.io.IOException;
import org.zbus.broker.Broker;
import org.zbus.broker.ZbusBroker;
import org.zbus.mq.Producer;
import org.zbus.net.http.Message;
/**
* 需要开启 zbus服务器。。消息中间件都是这样。
*
* 如果不开启zbus 需要嵌入到服务器中个,例如 zconsumer.java中
*
* @author SYZ
* @date 2016-8-12 下午05:38:35
* @version 1.0.0
* @see com.gbcom.frame.zbus.ZProduct
*/
public class ZProduct {
/** : (ZClient.main)
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
start();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
private static void start() throws IOException, InterruptedException{
Broker broker = new ZbusBroker("127.0.0.1:15555"); //SingleBroker
// Broker broker = new ZbusBroker("127.0.0.1:16666;127.0.0.1:16667"); //HaBroker
// Broker broker = new ZbusBroker("jvm"); //JvmBroker
Producer producer = new Producer(broker, "MyMQ");
producer.createMQ();//确定为创建消息队列需要显示调用
for (int i = 0; i < 10; i++) {
Message msg = new Message();
msg.setBody("hello world-"+i);
Message res = producer.sendSync(msg, 1000);
System.out.println(res);
}
broker.close();
}
}
分享到:
相关推荐
为您提供zbus消息服务框架下载,zbus核心是一个独立实现的小巧极速的消息队列(MQ),支持持久化与内存队列, 支持单播、广播、组播等多种消息通信模式;在MQ之上zbus完备地支持了RPC服务,RPC支持独立伺服,基于...
zbus消息服务框架 v1.0.0.zip
zbus核心是一个独立实现的小巧极速的消息队列(MQ),支持持久化与内存队列, 支持单播、广播、组播等多种消息通信模式;在MQ之上zbus完备地支持了RPC服务,RPC支持独立伺服,基于总线两种模式;同时zbus支持代理...
国内的消息中间件,简单易使用,解压直接运行就可以。
用于浏览器和节点的 zbus java脚本客户端.js
function loss = pf_zbus() [branchData,PQ,V1] = InputData(); PQ = PQ/1000; busCount = max(max(branchData(:,1:2))); Y = CreateY(branchData); Y22 = Y(2:end,2:end); Y21 = Y(2:end,1);
ZBUS algorithm matlab
实现了多种应用功能:微服务架构、基于zbus或motan的RPC框架、用户与权限管理、基于Redis的分布式session技术、基于zbus的消息框架、E-Mail后台发送技术、后台接口展示技术、分布式节点动态管理、自定义反向代理。...
轻量级服务总线,面向高性能、低时延、高可用特性调优,支持RPC,消息队列服务
Modification & Dynamic ZBUS
1.版本:matlab2014/2019a,内含运行结果,不会运行可私信 2.领域:智能优化算法、神经网络预测、信号处理、元胞自动机、图像...5.博客介绍:热爱科研的Matlab仿真开发者,修心和技术同步精进,matlab项目合作可si信
使用直接法的电力系统的 Zbus 和 Ybus
文件“data”中的每一行都有以下记录: 总线 1 总线 2 电阻抗其中 Bus1 和 Bus2 是所考虑的总线的总线编号,接下来的两个条目是它们之间的电阻和电抗。 警告: 任何分配了总线编号 = 1 的总线,必须连接到参考 (0)
ZBus-PHP应用程序的消息总线,管理应用程序流和插件之间的API消息传递。
基于隐式Zbus的配电网潮流计算程序,IEEE33节点
power system analysis notes on z bus and y bus and modification of z bus and y bus
实现了多种应用功能:微服务架构、基于zbus或motan的RPC框架、用户与权限管理、基于Redis的分布式session技术、基于zbus的消息框架、E-Mail后台发送技术、后台接口展示技术、分布式节点动态管理、自定义反向代理。...
修改和动态 ZBUS。 Case1 case2 case3 和 case4 的一般形式。 您可以使用此通用代码创建任何类型的总线系统。 第一次设置您的参考总线,然后通过输入“FROM”和“TO”继续添加总线。“FROM”和“TO”是总线编号。 ...