| New file |
| | |
|---|
| | | package com.dy.pipIrrMwTestRtu.tcpClient.upData; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol.p206V1.ProtocolConstantV206V1; |
|---|
| | | import com.dy.common.mw.protocol.p206V1.parse.global.GlCreate; |
|---|
| | | import com.dy.common.util.ByteUtil; |
|---|
| | | import org.apache.mina.core.session.IoSession; |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * @Author: liurunyu |
|---|
| | | * @Date: 2024/7/15 14:20 |
|---|
| | | * @Description |
|---|
| | | */ |
|---|
| | | public class UpData { |
|---|
| | | |
|---|
| | | protected static IoSession session ; |
|---|
| | | |
|---|
| | | private static Object synObj = new Object() ; |
|---|
| | | |
|---|
| | | public static void setSession(IoSession session){ |
|---|
| | | UpData.session = session ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | protected static void upSend(byte[] bs) throws Exception{ |
|---|
| | | synchronized (synObj){ |
|---|
| | | session.write(bs) ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | protected static byte[] creatHead(String rtuAddr, String code, byte ctrl)throws Exception { |
|---|
| | | byte[] bsHead = new byte[ProtocolConstantV206V1.lenHead2Code] ; |
|---|
| | | byte index = 0 ; |
|---|
| | | bsHead[index] = ProtocolConstantV206V1.P_Head_Byte ; |
|---|
| | | |
|---|
| | | index++ ; |
|---|
| | | bsHead[index] = 0 ;//帧长度 |
|---|
| | | |
|---|
| | | index++ ; |
|---|
| | | bsHead[index] = ProtocolConstantV206V1.P_Head_Byte ; |
|---|
| | | |
|---|
| | | index++ ; |
|---|
| | | bsHead[index] = ctrl; //控制域功能码 |
|---|
| | | |
|---|
| | | index++ ; |
|---|
| | | GlCreate.createRtuAddr4P206(rtuAddr, bsHead, index); |
|---|
| | | index += 5 ; |
|---|
| | | |
|---|
| | | ByteUtil.hex2Bytes(code, bsHead, index) ; |
|---|
| | | |
|---|
| | | return bsHead ; |
|---|
| | | } |
|---|
| | | } |
|---|
