ZBUS--轻量级MQ、RPC、服务总线

<dependency>
	<groupId>org.zbus</groupId>
	<artifactId>zbus</artifactId>
	<version>6.2.0-SNAPSHOT</version>
</dependency>

	//创建Broker代理
	BrokerConfig config = new BrokerConfig();
	config.setBrokerAddress("127.0.0.1:15555");
	final Broker broker = new SingleBroker(config);

	Producer producer = new Producer(broker, "MyMQ");
	producer.createMQ(); // 如果已经确定存在，不需要创建

	//创建消息，消息体可以是任意binary，应用协议交给使用者
	Message msg = new Message();
	msg.setBody("hello world");
	producer.sendSync(msg);  
	
	//销毁Broker
	broker.close();

	//创建Broker代表
	BrokerConfig brokerConfig = new BrokerConfig();
	brokerConfig.setBrokerAddress("127.0.0.1:15555");
	Broker broker = new SingleBroker(brokerConfig);
	
	MqConfig config = new MqConfig(); 
	config.setBroker(broker);
	config.setMq("MyMQ");
	
	//创建消费者
	@SuppressWarnings("resource")
	Consumer c = new Consumer(config);  
	
	c.onMessage(new MessageHandler() { 
		@Override
		public void handle(Message msg, Session sess) throws IOException {
			System.out.println(msg);
		}
	});

	//启动消费线程
	c.start();   

	BrokerConfig brokerConfig = new BrokerConfig();
	brokerConfig.setBrokerAddress("127.0.0.1:15555");
	Broker broker = new SingleBroker(brokerConfig);

	RpcProxy proxy = new RpcProxy(broker); 
	
	RpcConfig config = new RpcConfig();
	config.setMq("MyRpc"); 
	config.setTimeout(10000);  
	
	Interface hello = proxy.getService(Interface.class, config);


	Object[] res = hello.objectArray();
	for (Object obj : res) {
		System.out.println(obj);
	}

	Object[] array = new Object[] { getUser("rushmore"), "hong", true, 1,
			String.class };
	
	
	int saved = hello.saveObjectArray(array);
	System.out.println(saved);
	 
	Class<?> ret = hello.classTest(String.class);
	System.out.println(ret);
	
	
	broker.close();

<!-- 暴露的的接口实现示例 -->

<bean id="interface" class="org.zbus.rpc.biz.InterfaceImpl"></bean>

<bean id="serviceHandler" class="org.zbus.rpc.RpcServiceHandler">
	<constructor-arg>
		<list>
			<!-- 放入你需要的暴露的的接口 -->
			<ref bean="interface"/>
		</list>
	</constructor-arg>
</bean>
 
<bean id="broker" class="org.zbus.mq.SingleBroker">
	<constructor-arg>
		<bean class="org.zbus.mq.BrokerConfig">
			<property name="brokerAddress" value="127.0.0.1:15555" />
			<property name="maxTotal" value="20"/>
			<!-- 这里可以增加连接池参数配置，不配置使用默认值（参考commons-pool2） -->
		</bean>
	</constructor-arg>
</bean>

<!-- 默认调用了start方法，由Spring容器直接带起来注册到zbus总线上 -->
<bean id="zbusService" class="org.zbus.rpc.service.Service" init-method="start">
	<constructor-arg>  
		<bean class="org.zbus.rpc.service.ServiceConfig">
		    <!-- 支持多总线注册 -->
			<constructor-arg> 
				<list>
					<ref bean="broker"/> 
				</list>
			</constructor-arg>  
			<property name="mq" value="MyRpc"/>
			<property name="consumerCount" value="2"/>
			<property name="threadCount" value="20"/>
			<property name="serviceHandler" ref="serviceHandler"/>
		</bean>
	</constructor-arg>
</bean>

<bean id="broker" class="org.zbus.mq.SingleBroker">
	<constructor-arg>
		<bean class="org.zbus.mq.BrokerConfig">
			<property name="brokerAddress" value="127.0.0.1:15555" />
			<property name="maxTotal" value="20"/>
			<!-- 这里可以增加连接池参数配置，不配置使用默认值（参考commons-pool2） -->
		</bean>
	</constructor-arg>
</bean>

<bean id="rpcProxy" class="org.zbus.rpc.RpcProxy">
	<constructor-arg> <ref bean="broker"/> </constructor-arg>
</bean>

<!-- 动态代理由RpcProxy的getService生成，需要知道对应的MQ配置信息（第二个参数） -->
<bean id="interface" factory-bean="rpcProxy" factory-method="getService">
	<constructor-arg type="java.lang.Class" value="org.zbus.rpc.biz.Interface"/> 
	<constructor-arg>
		<bean class="org.zbus.rpc.RpcConfig"> 
			<property name="mq" value="MyRpc"/> 
		</bean>
	</constructor-arg>
</bean>

public static void main(String[] args) { 
	ApplicationContext context = new ClassPathXmlApplicationContext("zbusSpringClient.xml");
	
	Interface intf = (Interface) context.getBean("interface");
	
	System.out.println(intf.listMap());
}