dboss 支持http协议

public void httpReceived(ChannelHandlerContext ctx, MessageEvent event) throws Exception {
		DefaultHttpRequest request = (DefaultHttpRequest) event.getMessage();
		String url = "dboss:/" + request.getUri();
		ServiceInvoker invoker = new ServiceInvoker(serviceContext);
		Channel channel = ctx.getChannel();
		String result = null;
		try {
			result = invoker.accept(url);
		} catch (Exception e) {
			logger.error("Dboss invoker ERROR,RemoteAddress = "+channel.getRemoteAddress().toString(), e);
			ByteArrayOutputStream out = new ByteArrayOutputStream();
			PrintWriter pw = new PrintWriter(out);
			e.printStackTrace(pw);
			pw.close();
			result = new String(out.toByteArray());
		}

		if (channel.isOpen()) {
			HttpResponse response = new DefaultHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK);
			ChannelBuffer buffer = ChannelBuffers.copiedBuffer(result, "utf-8");
			response.setContent(buffer);
			response.setHeader("Content-Type", "text/html; charset=UTF-8");
			response.setHeader("Content-Length", String.valueOf(response.getContent().writerIndex()));
			channel.write(response).await();
			if(!request.isKeepAlive()){
				
				channel.disconnect();
				channel.close();
			}
		}
	}

 

	public void messageReceived(ChannelHandlerContext ctx, MessageEvent event) throws Exception {
		if (event.getMessage() instanceof DefaultHttpRequest) {
			httpReceived(ctx, event);
			return;
		}