old mode 100755
new mode 100644
| | |
| | | //本地Socket |
| | | private static Socket busSocket; |
| | | |
| | | |
| | | /// <summary> |
| | | /// 启动Socket接收和发送功能 |
| | | /// </summary> |
| | |
| | | |
| | | busSocket.BeginReceiveFrom (packet.Bytes, 0, packet.Bytes.Length, SocketFlags.None, ref packet.RemoteEndPoint, new AsyncCallback (asyncEndReceive), packet); |
| | | |
| | | |
| | | } |
| | | catch (Exception e) { |
| | | System.Threading.Thread.Sleep (1); |
| | |
| | | byte[] bytes = packet.Bytes; |
| | | packet.Bytes = new byte[len]; |
| | | System.Array.Copy(bytes, 0, packet.Bytes, 0, packet.Bytes.Length); |
| | | |
| | | packet.Manager(); |
| | | } |
| | | catch { } |
| | |
| | | } |
| | | tempPacket.FlagDateTime = System.DateTime.Now; |
| | | tempPacket.HaveSendCount++; |
| | | busSocket.BeginSendTo(tempPacket.Bytes, 0, tempPacket.Bytes.Length, SocketFlags.None, tempPacket.RemoteEndPoint, new AsyncCallback(asyncEndSend), tempPacket); |
| | | |
| | | //2020-01-14 增加本地通讯加密 |
| | | if (UserConfig.Instance.IsLocalEncrypt) { |
| | | var messageSend = Shared.Securitys.EncryptionService.AesEncryptPayload (tempPacket.Bytes, UserConfig.Instance.LocalEncryptKey); |
| | | tempPacket.Bytes = messageSend; |
| | | } |
| | | |
| | | busSocket.BeginSendTo(tempPacket.Bytes, 0, tempPacket.Bytes.Length, SocketFlags.None, tempPacket.RemoteEndPoint, new AsyncCallback(asyncEndSend), tempPacket); |
| | | } |
| | | catch { |
| | | |