| | |
|---|
| | | */ |
|---|
| | | @ResponseBody |
|---|
| | | @PostMapping("/sendMsgToClient") |
|---|
| | | public String sendMsgToClient(Integer id, Integer type, String msg){ |
|---|
| | | public String sendMsgToClient(Integer id, Integer type, String msg,String bussinessType){ |
|---|
| | | System.out.println("推送参数：" + id + "---" + type + "---" + msg); |
|---|
| | | if(type == 1){//用户端 |
|---|
| | | ChannelHandlerContext channel = NettyChannelMap.getData("Applets" + id);//小程序 |
|---|
| | | ChannelHandlerContext channel = NettyChannelMap.getData(bussinessType+":Applets" + id);//小程序 |
|---|
| | | if(null != channel){ |
|---|
| | | NettyWebSocketController.sendMsgToClient(channel, msg); |
|---|
| | | return JSON.toJSONString(ResultUtil.success()); |
|---|
| | | } |
|---|
| | | channel = NettyChannelMap.getData("USER" + id); |
|---|
| | | channel = NettyChannelMap.getData(bussinessType+":USER" + id); |
|---|
| | | if(null != channel){ |
|---|
| | | NettyServerController.sendMsgToClient(channel, msg); |
|---|
| | | return JSON.toJSONString(ResultUtil.success()); |
|---|
| | |
|---|
| | | |
|---|
| | | if(type == 2){//司机端 |
|---|
| | | System.out.println("长链接实例：" + JSON.toJSONString(NettyChannelMap.map)); |
|---|
| | | ChannelHandlerContext channel = NettyChannelMap.getData("DRIVER" + id); |
|---|
| | | ChannelHandlerContext channel = NettyChannelMap.getData(bussinessType+":DRIVER" + id); |
|---|
| | | if(null != channel){ |
|---|
| | | NettyServerController.sendMsgToClient(channel, msg); |
|---|
| | | return JSON.toJSONString(ResultUtil.success()); |
|---|
