C# Socket之異步TCP客戶端斷線重連

本文章向大家介紹C# Socket之異步TCP客戶端斷線重連，主要包括C# Socket之異步TCP客戶端斷線重連使用實(shí)例、應(yīng)用技巧、基本知識(shí)點(diǎn)總結(jié)和需要注意事項(xiàng)，具有一定的參考價(jià)值，需要的朋友可以參考一下。

        我們知道TCP通信是一種面向連接的Socket，針對(duì)于面向連接的TCP服務(wù)應(yīng)用，安全，但是效率低，它首先需要服務(wù)端開啟服務(wù)，然后客戶端才可以去連接，如果服務(wù)端沒有開啟通信服務(wù)或者連接之后再中途因?yàn)槟承┰驍嚅_連接了，那么都是會(huì)通信失敗的，所以我們這篇博客主要是對(duì)TCP通信加入兩個(gè)機(jī)制。1，客戶端開啟后未連接成功，自動(dòng)重連請求 2，若通信途中因?yàn)槟承┰驍嚅_連接了自動(dòng)重連機(jī)制  因?yàn)闇y試發(fā)現(xiàn)如果是程序運(yùn)行途中我們利用同步的方式重新連接的話連接時(shí)會(huì)出現(xiàn)程序卡頓的情況，這個(gè)對(duì)用戶的體驗(yàn)是非常不好的，為了避免這個(gè)情況，我們采用的是異步TCP通信的方式，代碼如下，這是一個(gè)單例腳本，無需掛載，程序開始時(shí)調(diào)用一下ConnectServer方法開啟通信就好，記得關(guān)閉程序時(shí)要調(diào)用一下Close方法來斷開掛起的異步連接，否則調(diào)試的時(shí)候通信會(huì)一直保存著。

/***********************************
 
*    Description：異步TCP客戶端
 
*    Mountpoint：這是一個(gè)單例腳本，無需掛載，直接調(diào)用即可
 
*    Date：2019.06.25
 
*    Version：unity版本2017.2.0f3
 
*    Author：LJF
 
***********************************/
 
using System.Collections;
 
using System.Collections.Generic;
 
using UnityEngine;
 
using System.Net;
 
using System.Net.Sockets;
 
using System;
 
using System.Text;
 
 
 
 
 
namespace LJF
 
{
 
//規(guī)范命名、添加注釋、合理封裝、限制訪問權(quán)限    
 
public class AsyncTcpClient
 
{
 
private string ip1;
 
private int port1;
 
byte[] ReadBytes = new byte[1024 * 1024];
 
//單例
 
public static AsyncTcpClient Instance
 
{
 
get
 
{
 
if (instance==null)
 
{
 
instance = new AsyncTcpClient();
 
}
 
return instance;
 
}
 
}
 
private static AsyncTcpClient instance;
 
 
 
System.Net.Sockets.TcpClient tcpClient;
 
 
 
//連接服務(wù)器
 
public void ConnectServer(string ip, int port)
 
{
 
//Debuger.EnableSave = true;
 
ip1 = ip;
 
port1 = port;
 
try
 
{
 
tcpClient = new System.Net.Sockets.TcpClient();//構(gòu)造Socket
 
tcpClient.BeginConnect(IPAddress.Parse(ip), port,Lianjie, null);//開始異步
 
}
 
catch (Exception e)
 
{
 
Debug.Log(e.Message);
 
}
 
}
 
 
 
//連接判斷
 
void Lianjie(IAsyncResult ar)
 
{
 
if (!tcpClient.Connected)
 
{
 
Debug.Log("服務(wù)器未開啟，嘗試重連。。。。。。");
 
tcpClient.BeginConnect(IPAddress.Parse(ip1), port1, Lianjie, null);
 
//IAsyncResult rest = tcpClient.BeginConnect(IPAddress.Parse(ip1), port1, Lianjie, null);
 
//bool scu= rest.AsyncWaitHandle.WaitOne(3000);
 
}
 
else
 
{
 
Debug.Log("連接上了");
 
tcpClient.EndConnect(ar);//結(jié)束異步連接
 
tcpClient.GetStream().BeginRead(ReadBytes, 0, ReadBytes.Length, ReceiveCallBack, null);
 
}
 
}
 
 
 
 
 
//接收消息
 
void ReceiveCallBack(IAsyncResult ar)
 
{
 
try
 
{
 
int len = tcpClient.GetStream().EndRead(ar);//結(jié)束異步讀取
 
if (len > 0)
 
{
 
 
 
string str = Encoding.UTF8.GetString(ReadBytes, 0,len);
 
str = Uri.UnescapeDataString(str);
 
//將接收到的消息寫入日志
 
//Debuger.Log(string.Format("收到主機(jī):{0}發(fā)來的消息|{1}", ip1, str));
 
//Debug.Log(str);
 
tcpClient.GetStream().BeginRead(ReadBytes, 0, ReadBytes.Length, ReceiveCallBack, null);
 
}
 
else
 
{
 
tcpClient = null;
 
Debug.Log("連接斷開,嘗試重連。。。。。。");
 
ConnectServer(ip1,port1);
 
}
 
}
 
catch (Exception e)
 
{
 
Debug.Log(e.Message);
 
}
 
}
 
 
 
//發(fā)送消息
 
public void SendMsg(string msg)
 
{
 
byte[] msgBytes = Encoding.UTF8.GetBytes(msg);
 
tcpClient.GetStream().BeginWrite(msgBytes, 0, msgBytes.Length, (ar) => {
 
tcpClient.GetStream().EndWrite(ar);//結(jié)束異步發(fā)送
 
}, null);//開始異步發(fā)送
 
}
 
 
 
/// <summary>
 
/// 斷開連接
 
/// </summary>
 
public void Close()
 
{
 
if (tcpClient != null && tcpClient.Client.Connected)
 
tcpClient.Close();
 
if (!tcpClient.Client.Connected)
 
{
 
tcpClient.Close();//斷開掛起的異步連接
 
}
 
}
 
 
 
}
 
}