package cn.org.hentai.jtt1078.server.backup;
|
|
import cn.org.hentai.jtt1078.entity.Jt1078Message;
|
import cn.org.hentai.jtt1078.publisher.PublishManager;
|
import cn.org.hentai.jtt1078.server.SessionManager;
|
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.SimpleChannelInboundHandler;
|
import io.netty.handler.timeout.IdleState;
|
import io.netty.handler.timeout.IdleStateEvent;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
/**
|
* Created by matrixy on 2019/4/9.
|
*/
|
public class Jt1078Handler extends SimpleChannelInboundHandler<Jt1078Message> {
|
static Logger logger = LoggerFactory.getLogger(Jt1078Handler.class);
|
|
@Override
|
protected void channelRead0(ChannelHandlerContext ctx, Jt1078Message msg) {
|
String sim = msg.getSim();
|
int channel = msg.getChannel();
|
String tag = sim + "-" + channel;
|
int sequence = msg.getSequence();
|
long timestamp = msg.getTimestampLong();
|
int pt = msg.getPt();
|
byte[] data = msg.getData();
|
if(data==null)
|
{
|
return;
|
}
|
int dataType = msg.getDataType();
|
int spm = msg.getSpm();
|
|
|
if (dataType == 0x00 || dataType == 0x01 || dataType == 0x02) {
|
PublishManager.getInstance().publishVideo(tag, sequence, timestamp, pt, data);
|
} else if (dataType == 0x03) {
|
PublishManager.getInstance().publishAudio(tag, sequence, timestamp, pt, data);
|
}
|
}
|
|
@Override
|
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
|
super.channelInactive(ctx);
|
release(ctx.channel());
|
}
|
|
@Override
|
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
|
// super.exceptionCaught(ctx, cause);
|
cause.printStackTrace();
|
release(ctx.channel());
|
ctx.close();
|
}
|
|
@Override
|
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
|
if (IdleStateEvent.class.isAssignableFrom(evt.getClass())) {
|
IdleStateEvent event = (IdleStateEvent) evt;
|
if (event.state() == IdleState.READER_IDLE) {
|
String tag = SessionManager.get(ctx.channel(), "tag");
|
logger.info("read timeout: {}", tag);
|
release(ctx.channel());
|
}
|
}
|
}
|
|
private void release(io.netty.channel.Channel channel) {
|
String tag = SessionManager.get(channel, "tag");
|
if (tag != null) {
|
logger.info("close netty channel: {}", tag);
|
PublishManager.getInstance().close(tag);
|
}
|
}
|
}
|
