From 6f1275502e0d7be1b919f9d6eb308436cc8958fa Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期四, 16 一月 2025 09:22:01 +0800
Subject: [PATCH] #
---
app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java | 156 +++++++++++++++++++++++++++++++++++++++++-----------
1 files changed, 123 insertions(+), 33 deletions(-)
diff --git a/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java b/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
index 13abdea..5df8f0e 100644
--- a/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
+++ b/app/src/main/java/com/example/agvcontroller/socket/NettyServerHandler.java
@@ -1,63 +1,124 @@
package com.example.agvcontroller.socket;
-import java.nio.charset.StandardCharsets;
+
import io.netty.buffer.ByteBuf;
+import io.netty.buffer.ByteBufUtil;
import io.netty.buffer.Unpooled;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
-import io.netty.channel.ChannelInboundHandlerAdapter;
import android.util.Log;
+
+import com.example.agvcontroller.Item;
+import com.example.agvcontroller.MainActivity;
+import com.example.agvcontroller.action.AGV_11_UP;
+import com.example.agvcontroller.action.AckMsgBuilder;
+import com.example.agvcontroller.met.AbstractInboundHandler;
+import com.example.agvcontroller.protocol.AGV_12_UP;
+import com.example.agvcontroller.protocol.AGV_13_UP;
+import com.example.agvcontroller.protocol.AGV_A1_DOWN;
+import com.example.agvcontroller.protocol.AGV_F0_DOWN;
+import com.example.agvcontroller.protocol.AGV_F0_UP;
+import com.example.agvcontroller.protocol.AGV_F0_UP8;
+import com.example.agvcontroller.protocol.AgvAction;
+import com.example.agvcontroller.protocol.AgvPackage;
+import com.example.agvcontroller.protocol.ProtocolType;
+
+
+import org.greenrobot.eventbus.EventBus;
+
import java.util.concurrent.ConcurrentHashMap;
-public class NettyServerHandler extends ChannelInboundHandlerAdapter {
+public class NettyServerHandler extends AbstractInboundHandler<AgvPackage> {
private static final String TAG = "NettyServerHandler";
private static ConcurrentHashMap<String, Channel> channelMap = new ConcurrentHashMap<>();
+
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception {
- String clientId = ctx.channel().remoteAddress().toString();
- channelMap.put(clientId, ctx.channel());
- Log.d(TAG, "Client connected: " + clientId);
+// String clientId = ctx.channel().remoteAddress().toString();
+// channelMap.put(clientId, ctx.channel());
+// EventBus.getDefault().post(new Item("",clientId,"3"));
+// Log.d(TAG, "Client connected: " + clientId);
}
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception {
String clientId = ctx.channel().remoteAddress().toString();
channelMap.remove(clientId);
+ EventBus.getDefault().post(clientId);
Log.d(TAG, "Client disconnected: " + clientId);
}
- @Override
- public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
- // 澶勭悊鎺ユ敹鍒扮殑娑堟伅
- ByteBuf byteBuf = (ByteBuf) msg;
- //byte[] data = new byte[byteBuf.readableBytes()];
- //byteBuf.readBytes(data);
- //String received = new String(data, StandardCharsets.UTF_8);
- //System.out.println("Received from client: " + received);
- //
- //// 鍥炲娑堟伅
- ////ByteBuf response = Unpooled.copiedBuffer("Response from server", StandardCharsets.UTF_8);
- ////ctx.writeAndFlush(response);
- //
- //byte[] responseHex = hexStringToByteArray("48656c6c6f20576f726c64"); // "Hello World" in hex
- //ByteBuf response = Unpooled.wrappedBuffer(responseHex);
- //ctx.writeAndFlush(response);
+// @Override
+// public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception {
+// // 澶勭悊鎺ユ敹鍒扮殑娑堟伅
+// ByteBuf byteBuf = (ByteBuf) msg;
+// try {
+// while (byteBuf.isReadable()) {
+// byte[] bytes = new byte[byteBuf.readableBytes()];
+// byteBuf.readBytes(bytes);
+// String hexString = bytesToHex(bytes);
+// // 鑾峰彇agv淇℃伅 娣诲姞鍒發ist涓�
+// Log.d(TAG, "ctx: " + ctx.channel().remoteAddress().toString() );
+// Log.d(TAG, "Received: " + hexString);
+// }
+// } finally {
+// byteBuf.release();
+// }
+// }
- try {
- while (byteBuf.isReadable()) {
- byte[] bytes = new byte[byteBuf.readableBytes()];
- byteBuf.readBytes(bytes);
- String hexString = bytesToHex(bytes);
- // 鑾峰彇agv淇℃伅 娣诲姞鍒發ist涓�
- Log.d(TAG, "ctx: " + ctx.channel().remoteAddress().toString() );
- Log.d(TAG, "Received: " + hexString);
- }
- } finally {
- byteBuf.release();
+ @Override
+ protected boolean channelRead0(ChannelHandlerContext ctx, AgvPackage pac) throws Exception {
+ String clientId = ctx.channel().remoteAddress().toString();
+ Log.i("clientId--->",clientId);
+ Log.i("substring",pac.toString());
+ String serialNum = pac.getBody().getMessageBody().getSerialNo();
+ Log.i("substring",serialNum);
+ MainActivity.map.put(serialNum, Boolean.TRUE);
+ // ack
+ ProtocolType ackType = isNeedAck(pac);
+ final String uniqueNo = pac.getHeader().getUniqueNo();
+ String agvNo;
+ label : switch (pac.getHeader().getProtocolType()){
+ case ACTION_COMPLETE: // 鍔ㄤ綔瀹屾垚鏁版嵁鍖�
+ AGV_11_UP agv_11_up = (AGV_11_UP) pac.getBody().getMessageBody();
+// redis.push(RedisConstant.AGV_COMPLETE_FLAG, AgvProtocol.build(uniqueNo).setMessageBody(agv_11_up));
+ // 鍔ㄤ綔瀹屾垚搴旂瓟
+ if (null != ackType) {
+ AgvPackage ackPac = AckMsgBuilder.ofSuccess(pac, ackType);
+ AGV_A1_DOWN agv_a1_down = (AGV_A1_DOWN) ackPac.getBody().getMessageBody();
+ agv_a1_down.setAckSign((byte) agv_11_up.getCompleteCode());
+ ctx.writeAndFlush(ackPac);
+ }
+ break label;
+ case DATA_CODE_REPORT:
+ AGV_12_UP agv_12_up = (AGV_12_UP) pac.getBody().getMessageBody();
+ agvNo = pac.getHeader().getUniqueNo();
+ channelMap.put(clientId, ctx.channel());
+ EventBus.getDefault().post(new Item("",clientId,agvNo));
+ break label;
+ case DATA_WITHOUT_CODE_REPORT:
+ AGV_13_UP agv_13_up = (AGV_13_UP) pac.getBody().getMessageBody();
+ agvNo = pac.getHeader().getUniqueNo();
+ channelMap.put(clientId, ctx.channel());
+ EventBus.getDefault().post(new Item("",clientId,agvNo));
+ break label;
+ case LOGIN_REPORT:
+ AGV_F0_UP agv_f0_up = (AGV_F0_UP) pac.getBody().getMessageBody();
+ if (null != ackType) {
+ AgvPackage ackPac = AckMsgBuilder.ofSuccess(pac, ackType);
+ AGV_F0_DOWN agv_f0_down = (AGV_F0_DOWN) ackPac.getBody().getMessageBody();
+ ctx.writeAndFlush(ackPac);
+ }
+ agvNo = pac.getHeader().getUniqueNo();
+ channelMap.put(clientId, ctx.channel());
+ EventBus.getDefault().post(new Item("",clientId,agvNo));
+ break label;
+
}
+ return false;
}
private String bytesToHex(byte[] bytes) {
@@ -82,7 +143,22 @@
Channel channel = channelMap.get(clientId);
if (channel != null && channel.isActive()) {
ByteBuf buf = Unpooled.wrappedBuffer(message);
+ String upperCase = ByteBufUtil.hexDump(buf).toUpperCase();
+ Log.d(TAG, "upperCase " + upperCase);
channel.writeAndFlush(buf);
+ } else {
+ Log.d(TAG, "Client " + clientId + " is not connected");
+ }
+ }
+
+ public static void sendMessageToClient(String clientId, AgvAction<?> action) {
+
+
+
+ Channel channel = channelMap.get(clientId);
+ if (channel != null && channel.isActive()) {
+
+ channel.writeAndFlush(action);
} else {
Log.d(TAG, "Client " + clientId + " is not connected");
}
@@ -94,4 +170,18 @@
ctx.close();
}
+ /**
+ * 鏈嶅姟鍣ㄦ槸鍚﹂渶瑕佸簲绛�
+ */
+ public static ProtocolType isNeedAck(AgvPackage pac) {
+ switch (pac.getHeader().getProtocolType()) {
+ case ACTION_COMPLETE:
+ return ProtocolType.ACTION_SUCCESS_ACK;
+ case LOGIN_REPORT:
+ return ProtocolType.LOGIN_ACK;
+ default:
+ return null;
+ }
+ }
+
}
--
Gitblit v1.9.1