基于cglib 反射 netty http1.0

knight_black_bob

浏览: 859408 次
性别:
来自: 北京

最近访客更多访客>>

bian1024

lli

cqh520llr

hxgdragon

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

netty

cglib 反射 netty http1.0 java

数据源代码位置：http://knight-black-bob.iteye.com/blog/2256698

netty 代码位置：http://knight-black-bob.iteye.com/blog/2256690

package com.netty.dto;

import com.google.gson.Gson;
import com.google.gson.GsonBuilder;

public class ResponceInfo {

	private Integer code; 
	private String message; 
	private Object data; 
	 
	
	public ResponceInfo() { 
	}
	
	public ResponceInfo(Integer code, String message, Object data) { 
		this.code = code;
		this.message = message;
		this.data = data;
	}
	
	public Integer getCode() {
		return code;
	}
	public void setCode(Integer code) {
		this.code = code;
	}
	public String getMessage() {
		return message;
	}
	public void setMessage(String message) {
		this.message = message;
	}
	public Object getData() {
		return data;
	}
	public void setData(Object data) {
		this.data = data;
	}
	
	@Override
	public String toString() {
		Gson gson=new GsonBuilder()
			    .disableHtmlEscaping()
			    .serializeNulls()
			    .create();;
		return gson.toJson(this);
	}
}

package com.netty.business;

import org.springframework.cglib.reflect.FastClass;
import org.springframework.cglib.reflect.FastMethod; 

import com.netty.dto.ResponceInfo;

public class CGLibCode {
	
	public static  ResponceInfo execute(Object targetObject,String methodName,Class<?>[] parameterTypes, Object[] parameters){
		try {
			FastClass serviceFastClass = FastClass.create(targetObject.getClass());
			FastMethod serviceFastMethod = serviceFastClass.getMethod(methodName, parameterTypes);
			return (ResponceInfo)serviceFastMethod.invoke(targetObject, parameters);
		} catch (Exception e) {
			return null ;
		}
	}

}

package com.netty.business;

import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;

import org.apache.log4j.Logger;
import org.springframework.util.StringUtils;

import com.common.util.ParamsUtils;
import com.google.common.base.Strings;  
import com.netty.service.NettyServicePool;

import io.netty.handler.codec.http.HttpMethod;
import io.netty.handler.codec.http.HttpRequest;
import io.netty.handler.codec.http.QueryStringDecoder;
import io.netty.handler.codec.http.multipart.Attribute;
import io.netty.handler.codec.http.multipart.DefaultHttpDataFactory;
import io.netty.handler.codec.http.multipart.HttpPostRequestDecoder;
import io.netty.handler.codec.http.multipart.InterfaceHttpData;
import io.netty.handler.codec.http.multipart.InterfaceHttpData.HttpDataType;

public class BusinessHandler {

	private static Logger logger = Logger.getLogger(BusinessHandler.class);
	private static HttpRequest req;

	public BusinessHandler(){
		req = null;
	}
	
	public static HttpRequest getReq() {
		return req;
	}

	public static void setReq(HttpRequest req) {
		BusinessHandler.req = req;
	}

	public BusinessHandler(HttpRequest req) { 
		BusinessHandler.req = req;
	}

	public    String handler(){
		Map<String, List<String>> _params=null;
		String srcUrl = req.getUri();
		try {
			if(req.getMethod()==HttpMethod.GET)
				_params=_getParams(srcUrl);
			else
				_params=_postParams(srcUrl);
		} catch (Exception e) {}
		return _execute(_params);
	}
	
	private static String _execute(Map<String, List<String>> params) {
		String cln=ParamsUtils.getStringFromMap(params, "cln");//接口名
		String mod=ParamsUtils.getStringFromMap(params, "mod");//方法名
		if(StringUtils.hasText(cln) && StringUtils.hasText(mod)){
			Object  autoService= NettyServicePool.NETTYSERVICES.get(cln);
			if(null!=autoService){
				params.remove("cln");
				params.remove("mod");
				String[] ps=new String[params.size()];
				Class<?>[] cs=new Class<?>[params.size()];
				int i=0;
				for (Entry<String, List<String>> e : params.entrySet()) {
					cs[i]=String.class;
					String _value=null ;
					if(null!=e.getValue() && e.getValue().size()>0)
						_value=e.getValue().get(0);
					ps[i]=_value;
					i++; 
				}
				return  CGLibCode.execute(autoService, mod, cs, ps).toString();
			}
		}  
		return null;
	}

	private static Map<String, List<String>> _postParams(String srcUrl) throws IOException {
		HttpPostRequestDecoder decoder = new HttpPostRequestDecoder(new DefaultHttpDataFactory(false), req);
		Map<String, List<String>> params=new HashMap<String, List<String>>();
		if (decoder != null) {
			List<InterfaceHttpData> postDatas = decoder.getBodyHttpDatas(); 
			for (InterfaceHttpData postData:postDatas) {
				if (postData.getHttpDataType() == HttpDataType.Attribute){
					Attribute attribute = (Attribute) postData;
					String v=attribute.getValue();
					List<String> list=new ArrayList<String>();
					list.add(Strings.nullToEmpty(v));
					params.put(attribute.getName(), list);
				}
			}
		}
		return params;
	}

	
	//未加密
	private static Map<String, List<String>> _getParams(String srcUrl) {
		QueryStringDecoder decoder = new QueryStringDecoder(srcUrl);
		Map<String, List<String>> params=new HashMap<String, List<String>>();
		params = decoder.parameters();
		return params;
	}
}

package com.netty.core;
 
import org.apache.log4j.Logger;
  
import com.netty.business.BusinessHandler;

import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFutureListener;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.codec.http.DefaultFullHttpResponse;
import io.netty.handler.codec.http.FullHttpResponse;
import io.netty.handler.codec.http.HttpHeaders;
import io.netty.handler.codec.http.HttpRequest;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.netty.handler.codec.http.HttpVersion;
import io.netty.handler.codec.http.HttpHeaders.Names; 

public class NettyServerHandler extends ChannelInboundHandlerAdapter {
	
	Logger logger = Logger.getLogger(NettyServerHandler.class);
	 
	
	@Override
	public void channelRead(ChannelHandlerContext ctx, Object msg)
			throws Exception { 
		logger.info("channelRead " + msg);
		if (msg instanceof HttpRequest){
			HttpRequest req = (HttpRequest) msg;
			logger.info(req.getUri());
			if(HttpHeaders.is100ContinueExpected(req)){
				ctx.write(new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.CONTINUE));
			}
			String _result=new BusinessHandler(req).handler();
			logger.info("_result : " + _result);
			FullHttpResponse  response = new DefaultFullHttpResponse(HttpVersion.HTTP_1_1, HttpResponseStatus.OK, Unpooled.wrappedBuffer(_result.getBytes()));
			response.headers().set(Names.CONTENT_TYPE, "text/html; charset=utf-8");
			response.headers().set(Names.CONTENT_LENGTH, response.content().readableBytes());
			ctx.write(response).addListener(ChannelFutureListener.CLOSE);
		} 
	}  
	
	@Override
	public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
		logger.info("exceptionCaught ");
		ctx.close();
	}
	

	@Override
	public void channelReadComplete(ChannelHandlerContext ctx) {
		logger.info("channelReadComplete ");
		ctx.flush();
	}
	
}

package test.netty;

import java.net.URI;

import org.junit.Test; 

import io.netty.bootstrap.Bootstrap;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioSocketChannel;
import io.netty.handler.codec.http.DefaultFullHttpRequest;
import io.netty.handler.codec.http.HttpHeaders;
import io.netty.handler.codec.http.HttpMethod;
import io.netty.handler.codec.http.HttpRequestEncoder;
import io.netty.handler.codec.http.HttpResponseDecoder;
import io.netty.handler.codec.http.HttpVersion;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.codec.http.HttpContent; 
import io.netty.handler.codec.http.HttpResponse;
 
public class NettyClient2Test {

	public void connect(String host, int port) throws Exception {
        EventLoopGroup workerGroup = new NioEventLoopGroup();

        try {
            Bootstrap b = new Bootstrap();
            b.group(workerGroup);
            b.channel(NioSocketChannel.class);
            b.option(ChannelOption.SO_KEEPALIVE, true);
            b.handler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) throws Exception {
                    // 客户端接收到的是httpResponse响应，所以要使用HttpResponseDecoder进行解码
                    ch.pipeline().addLast(new HttpResponseDecoder());
                    // 客户端发送的是httprequest，所以要使用HttpRequestEncoder进行编码
                    ch.pipeline().addLast(new HttpRequestEncoder());
                    ch.pipeline().addLast(new HttpClientInboundHandler2());
                }
            });

            // Start the client.
            ChannelFuture f = b.connect(host, port).sync();

            URI uri = new URI("http://127.0.0.1:8443?cln=mifiDeviceService&mod=getMifiDeviceById&id="+6);
            String msg = "cln=mifiDeviceService&mod=getMifiDeviceById&id=6";
            DefaultFullHttpRequest request = new DefaultFullHttpRequest(HttpVersion.HTTP_1_1, HttpMethod.GET,
                    uri.toASCIIString(), Unpooled.wrappedBuffer(msg.getBytes("UTF-8")));

            // 构建http请求
            request.headers().set(HttpHeaders.Names.HOST, host);
            request.headers().set(HttpHeaders.Names.CONNECTION, HttpHeaders.Values.KEEP_ALIVE);
            request.headers().set(HttpHeaders.Names.CONTENT_LENGTH, request.content().readableBytes());
            // 发送http请求
            f.channel().write(request);
            f.channel().flush();
           // f.channel().closeFuture().sync();
        } finally {
            workerGroup.shutdownGracefully();
        }

    }
 
	@Test
	public void Test(){
		try{ 
			NettyClient2Test client = new NettyClient2Test();
	        client.connect("127.0.0.1", 8443);
		}catch(Exception e){
			e.printStackTrace();
		}
	}
}

class HttpClientInboundHandler2 extends ChannelInboundHandlerAdapter {

    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
        if (msg instanceof HttpResponse) 
        {
            HttpResponse response = (HttpResponse) msg;
            System.out.println("CONTENT_TYPE:" + response.headers().get(HttpHeaders.Names.CONTENT_TYPE));
        }
        if(msg instanceof HttpContent)
        {
            HttpContent content = (HttpContent)msg;
            ByteBuf buf = content.content();
            System.out.println(buf.toString(io.netty.util.CharsetUtil.UTF_8));
            buf.release();
        }
    }
}

package com.mifi.serviceimpl;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import com.common.util.netty.StatusCode;
import com.mifi.bean.MifiDevice;
import com.mifi.dao.MifiDeviceDao;
import com.mifi.service.MifiDeviceService;
import com.netty.dto.ResponceInfo;
import com.netty.service.NettyServerService;

@NettyServerService(name="mifiDeviceService")
@Service
public class MifiDeviceServiceImpl implements MifiDeviceService {

	@Autowired
	MifiDeviceDao dao;
	
	// 1 true 0, false
 	public  ResponceInfo  hasMifiDeviceById(String id){
		//return dao.getMifiDeviceById(id) == null ? false : true ;
 		int  result=0;
 		if(dao.getMifiDeviceById(Long.parseLong(id)) != null)
 		 result=1;
		return new  ResponceInfo(StatusCode.STATUS_SUCCCESS,StatusCode.MSG_SUCCESS,result);
	}
	
	public  ResponceInfo getMifiDeviceById(String id){
		MifiDevice   mifiDevice = null;
		try{
              mifiDevice = dao.getMifiDeviceById(Long.parseLong(id));
		}catch(Exception e){
			
		}
		return new  ResponceInfo(StatusCode.STATUS_SUCCCESS,StatusCode.MSG_SUCCESS,mifiDevice);
		
	}
	
	 public ResponceInfo  findAllMifiDevices(){
		 List<MifiDevice> mlist =  null ;
		 try{
			 mlist= dao.findAllMifiDevices();
		}catch(Exception e){
			
		}
		 return new  ResponceInfo(StatusCode.STATUS_SUCCCESS,StatusCode.MSG_SUCCESS,mlist);
			
	 } 
	 
	 public ResponceInfo addMifiDevice(MifiDevice mifiDevice){
		 int  result=0;
		 try{
		 		 result=1;
			 dao.addMifiDevice(mifiDevice);
		}catch(Exception e){
			
		}
		 return new  ResponceInfo(StatusCode.STATUS_SUCCCESS,StatusCode.MSG_SUCCESS,result);
	 }
	 
	 public ResponceInfo delMifiDeviceById(String id){
		 int  result=0;
		 try{
		 		 result=1;
		 		 dao.delMifiDeviceById(Long.parseLong(id));
		}catch(Exception e){
			
		}
		 return new  ResponceInfo(StatusCode.STATUS_SUCCCESS,StatusCode.MSG_SUCCESS,result);
		
	 }
	 
	 public ResponceInfo updateMifiDevice(MifiDevice mifiDevice){
		 int  result=0;
		 try{
		 		 result=1;
		 		 dao.updateMifiDevice(mifiDevice);
		}catch(Exception e){
			
		}
		 return new  ResponceInfo(StatusCode.STATUS_SUCCCESS,StatusCode.MSG_SUCCESS,result);
	 }
	
}