<dependency>
	<groupId>org.zbus</groupId>
	<artifactId>zbus-remoting</artifactId>
	<version>5.2.0</version>
</dependency>

public class MyRemotingServer extends RemotingServer {
	//个性化定义Message中的那部分解释为命令，这里为了支持浏览器直接访问，把Message中的path理解为command
	@Override
	public String findHandlerKey(Message msg) { 
		String cmd = msg.getCommand();
		if(cmd == null){
			cmd = msg.getPath();
		}
		return cmd;
	}
	
	public MyRemotingServer(int serverPort) throws IOException {
		super(serverPort); 
		//注册命令处理Callback
		this.registerHandler("hello", new MessageHandler() {
			public void handleMessage(Message msg, Session sess) throws IOException {
				System.out.println(msg);
				msg.setStatus("200");   
				msg.setBody("hello world");
				sess.write(msg);
			}
		});
	}
	public static void main(String[] args) throws Exception {   
		@SuppressWarnings("resource")
		MyRemotingServer server = new MyRemotingServer(80);
		server.start(); 
	}
}

public class MyRemotingClient {
	public static void main(String[] args) throws Exception {  
		//1) 创建ClientDispatcherManager
		ClientDispatcherManager clientDispatcherManager = new ClientDispatcherManager();
		
		//2) 创建RemotingClient
		RemotingClient client = new RemotingClient("127.0.0.1:80", clientDispatcherManager);
		Message msg = new Message(); 
		msg.setCommand("hello");
		//3）同步请求
		Message res = client.invokeSync(msg);
		System.out.println(res);
		
		//4）释放链接资源与线程池相关资源
		client.close();
		clientDispatcherManager.close();
	} 
}