ios apns java codec 防止粘包

 public Bootstrap newBootstrap(Bootstrap bootstrap,final PushHandler phandler) {bootstrap.handler(new ChannelInitializer<SocketChannel>() {@Overrideprotected void initChannel(SocketChannel ch) throws Exception {ChannelPipeline pipeline = ch.pipeline();if (isSsl) {SSLContext sslContext = SSLUtil.initSSLContext(credentials.getCertification(), credentials.getPassword());SSLEngine sslEngine = sslContext.createSSLEngine();sslEngine.setUseClientMode(true);pipeline.addLast("ssl", new SslHandler(sslEngine));}if (Constant.debug) {pipeline.addLast("log", new LoggingHandler(LogLevel.DEBUG));}pipeline.addLast("encoder", new Encoder());pipeline.addLast("decoder", new Decoder());pipeline.addLast("pushHandler", phandler);}});return bootstrap;}

package com.couriusby.apns.codec;import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;import java.util.List;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import com.curiousby.apns.message.ErrorResponse;public class Decoder extends ByteToMessageDecoder
{static final Logger logger = LoggerFactory.getLogger(Decoder.class);// 据文档： command + status + identifier = 1 + 1 + 4static final int responseSize = 6;@Overrideprotected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception{// logger.debug("readableBytes:" + in.readableBytes());if (in.readableBytes() >= responseSize){ErrorResponse errorResponse = new ErrorResponse();errorResponse.setCommond(in.readByte());errorResponse.setStatus(in.readByte());errorResponse.setIdentifier(in.readInt());errorResponse.setErrorMsg(ErrorResponse.getErrorMsgByStatus(errorResponse.getStatus()));out.add(errorResponse);}logger.debug("decoder:" + out);}
}

package com.curiousby.apns.codec;import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;import java.nio.charset.Charset;
import java.util.Date;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import com.curiousby.apns.message.Item;
import com.curiousby.apns.message.Notification;/*** <pre>* 1 byte      4 byte * command + frameLength + item + item + ... + item* *         1 byte     2 byte * item = itemId + itemLength + itemData* * itemData据不同的类型有不同的长度：* * </pre>* * 采用组发送的方式，一次发送一系列的消息，然后每个消息的notificationIdentifier都是连续的，* 这样，如果apple的服务器返回错误，那么可以从错误里的Identifier知道是哪个出错了，然后重发下面的消息。*/
public class Encoder extends MessageToByteEncoder<Notification>
{static final Logger logger = LoggerFactory.getLogger(Encoder.class);// TODO 这个到底要不要做成static的，static的可能容易调试点，不然每个线程都有一个计数的话，可能会比较乱// TODO 处理超出int范围，再重新从0开始的逻辑int identifier = 0;static final Charset utf8 = Charset.forName("UTF-8");// 据apple的文档，这个值就是2，据其它地方看到的资料，有0和1的版本。static final int COMMAND = 2;static final int defaultExpirationDate = 0;@Overrideprotected void encode(ChannelHandlerContext ctx, Notification notification, ByteBuf out) throws Exception{// logger.debug("NotificationEncoder:" + notification);// String data =// "02000000770100205CA6A718250E1868A8EB7D8964D3E8A051B009268A3D710D0D8CC6591572890802003F7B22617073223A7B22736F756E64223A2264656661756C74222C22616C657274223A2252696E672072696E672C204E656F2E222C226261646765223A317D7D030004000000650400047FFFFFFF0500010A";// out.writeBytes(Hex.decodeHex(data.toCharArray()));out.writeByte(COMMAND);out.writeInt(0); // 预先写入frameLenint frameLenIndex = out.writerIndex();// 这里不检验数据格式的正确性，上层要检查// 开始写入items// 开始写入Device tokenout.writeByte(Item.DEVICE_TOKEN);out.writeShort(32);out.writeBytes(notification.getToken());// 写入Payloadout.writeByte(Item.PAYLOAD);out.writeShort(notification.getPayload().length);out.writeBytes(notification.getPayload());// 写入Notification identifierout.writeByte(Item.NOTIFICATION_IDENTIFIER);out.writeShort(4);out.writeInt(notification.getId());// 写入Expiration dateout.writeByte(Item.EXPIRATION_DATE);out.writeShort(4);Date expirationDate = notification.getExpirationDate();if (expirationDate == null){out.writeInt(0);}else{out.writeInt((int) (expirationDate.getTime() / 1000));}// 写入Priorityout.writeByte(Item.PRIORITY);out.writeShort(1);out.writeByte(notification.getPriority());// 回退到该写入frameLen的位置，写入frameLen，再重新设置write indexint currentWriteIndex = out.writerIndex();out.writerIndex(1); // 因为command后面就是len，而command是1 byte。out.writeInt(currentWriteIndex - frameLenIndex);out.writerIndex(currentWriteIndex);}
}

捐助开发者

在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。 当然，有钱捧个钱场（支持支付宝和微信捐助，加入it技术扣扣群），没钱捧个人场，谢谢各位。

 
 
 谢谢您的赞助，我会做的更好！