提交推送服务

Pu Zhibing

2025-08-05 4872bb7719c4ccaaab99438af3d987787c818c2a

 MessagePushTravel/src/main/java/com/sinata/push/controller/NettyController.java

@@ -18,11 +18,6 @@
@RequestMapping("/netty")
public class NettyController {
    
    @Autowired
    private NettyServerController nettyServerController;
    
    @Autowired
    private NettyWebSocketController nettyWebSocketController;


    /**
@@ -37,12 +32,12 @@
        if(type == 1){//用户端
            ChannelHandlerContext channel = NettyChannelMap.getData("Applets" + id);//小程序
            if(null != channel){
                nettyWebSocketController.sendMsgToClient(channel, msg);
                NettyWebSocketController.sendMsgToClient(channel, msg);
                return JSON.toJSONString(ResultUtil.success());
            }
            channel = NettyChannelMap.getData("USER" + id);
            if(null != channel){
                nettyServerController.sendMsgToClient(channel, msg);
               NettyServerController.sendMsgToClient(channel, msg);
                return JSON.toJSONString(ResultUtil.success());
            }
            return JSON.toJSONString(ResultUtil.error("推送失败-----用户id=" + id));
@@ -53,7 +48,7 @@
            System.out.println("长链接实例：" + JSON.toJSONString(NettyChannelMap.map));
            ChannelHandlerContext channel = NettyChannelMap.getData("DRIVER" + id);
            if(null != channel){
                nettyServerController.sendMsgToClient(channel, msg);
                NettyServerController.sendMsgToClient(channel, msg);
                return JSON.toJSONString(ResultUtil.success());
            }
            return JSON.toJSONString(ResultUtil.error("推送失败-----司机id=" + id));