package com.walker.tcp.handler;

import com.walker.tcp.Message;
import com.walker.tcp.Request;

/**
 * 系统默认长连接处理对象。该对象被重构
 * @author 时克英
 * @date 2018-11-27
 *
 */
@Deprecated
public class MyLongHandler extends MyMessageHandler {

	public MyLongHandler(){
		this.setEmptyMsgDisconnect(true);
	}

	@Override
	protected Request<?> createRequest(Message msg) throws Exception {
		throw new UnsupportedOperationException("该类型消息暂未实现。");
//		if(this.getMapper() == null){
//			throw new IllegalArgumentException(MSG_REQUEST_ERROR);
//		}
//		MessageProtocolResolver resolver = (MessageProtocolResolver)ConvertorUtils.getProtocolResolver(msg, getProtocolResolverList());
//		if(resolver == null){
//			throw new IllegalArgumentException("protocolResolver not found, msg : " + msg);
//		}
//
//		// 去掉报文中的分隔符，因为netty打开了显示分隔符
//		String content = msg.getPayload().toString().substring(0, msg.length()-resolver.getDelimiter().length());
//
//		String protocol = resolver.getProtocolNum(content, content.length());
//		String clazz = this.getMapper().get(protocol);
//		if(StringUtils.isEmpty(clazz)){
//			throw new IllegalArgumentException("请求协议对应的request类不存在。protocol = " + protocol + ", msg = " + content);
//		}
//		try {
//			Class<?> clazzRequest = ClassUtils.forName(clazz, this.getClass().getClassLoader());
//			AbstractStringRequest request = (AbstractStringRequest)clazzRequest.newInstance();
//			request.fromSource(content);
////			request.setProtocolResolver(resolver);
//			request.setProtocolResolverId(resolver.getOrder());
//			return request;
//
//		} catch (ClassNotFoundException e) {
//			logger.error("根据映射创建request对象错误：" + e.getMessage(), e);
//			throw new Exception(e);
//		}
	}

}