| | |
|---|
| | | /// </summary> |
|---|
| | | public void Connect() |
|---|
| | | { |
|---|
| | | return; |
|---|
| | | lock (lockObj) |
|---|
| | | { |
|---|
| | | if (isConnected) |
|---|
| | |
|---|
| | | { |
|---|
| | | try |
|---|
| | | { |
|---|
| | | //_tcpClient.ReceiveTimeout = |
|---|
| | | _tcpClient.Connect(IPAddress.Parse(_ip), 8586); |
|---|
| | | ReceiveMessage();//开启线程，不停接收消息 |
|---|
| | | isConnected = true; |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | Thread.Sleep(1000); |
|---|
| | | |
|---|
| | | |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | connectThread.Start(); |
|---|
| | |
|---|
| | | /// <param name="bytes">需要发送的字节</param> |
|---|
| | | public void SendMessage(byte[] bytes) |
|---|
| | | { |
|---|
| | | return; |
|---|
| | | #if __IOS__ |
|---|
| | | |
|---|
| | | #endif |
|---|
| | | if (heartBeatLogIdList.Count > 3) |
|---|
| | | { |
|---|
| | | try |
|---|
| | |
|---|
| | | private DateTime heartBeatTime; |
|---|
| | | public void HeartBeat() |
|---|
| | | { |
|---|
| | | return; |
|---|
| | | lock (lockObj) |
|---|
| | | { |
|---|
| | | if (heartBeatThread == null) |
|---|
| | |
|---|
| | | } |
|---|
| | | var tcpDataString = System.Text.Encoding.UTF8.GetString(arrMsgRec, 0, arrMsgRec.Length); |
|---|
| | | |
|---|
| | | |
|---|
| | | if (!string.IsNullOrEmpty(tcpDataString)) |
|---|
| | | { |
|---|
| | | MainPage.Log($"局域网tcp数据接收"); |
|---|
| | | Control.Ins.ConvertReceiveData(arrMsgRec, null); |
|---|
| | | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | catch (Exception) { } |
|---|
| | |
|---|
| | | MainPage.Log($"tcp ReceiveMessage error :{ex.Message}"); |
|---|
| | | } |
|---|
| | | }); |
|---|
| | | //receiveThread.IsBackground = true; |
|---|
| | | receiveThread.Start(); |
|---|
| | | } |
|---|
| | | else |
|---|
