在unity做強(qiáng)聯(lián)網(wǎng)游戲的時(shí)候一般會(huì)選擇用tcp來(lái)做通信（據(jù)說(shuō)有一種udp的傳輸具有更高的效率），而接收信息的方法上一般會(huì)選擇新建一個(gè)線(xiàn)程循環(huán)讀取。

克拉瑪依區(qū)ssl適用于網(wǎng)站、小程序/APP、API接口等需要進(jìn)行數(shù)據(jù)傳輸應(yīng)用場(chǎng)景，ssl證書(shū)未來(lái)市場(chǎng)廣闊！成為創(chuàng)新互聯(lián)公司的ssl證書(shū)銷(xiāo)售渠道，可以享受市場(chǎng)價(jià)格4-6折優(yōu)惠！如果有意向歡迎電話(huà)聯(lián)系或者加微信：028-86922220（備注：SSL證書(shū)合作）期待與您的合作！

今天在我們項(xiàng)目上看到另外的一種方法。這里記錄一下。

首先建立tcp連接

#using System.Net.Sockets;  

TcpClient tcpClient = new TcpClient();  
tcpClient .BeginConnect(address,port,new AsyncCallback(this.OnConnect),result);

可以看到這里用的是異步通信回調(diào)函數(shù)AsyncCallback

private void OnConnect(IAsyncResult ar)  
{  
    ConnectResult result = ar.AsyncState as ConnectRsult;  
    try  
    {  
        result.client.EndConnect(ar);  
        int size = HeaderLength;//定好的表頭大小  
        byte[] readBuf = new byte[size];  
        result.client.GetStream().BeginRead(readBuf,0,size,new AsyncCallback(this.OnRead),new RecvIremObject(result.client,readBuf,size));  
    }  
    catch(System.Net.Sockets.SocketException e)  
    {  
    }  
}

上面是連接成功后的函數(shù)，連接成功后就可以斷開(kāi)連接并開(kāi)始接受表頭；同樣是在異步通信回調(diào)函數(shù)內(nèi)使用

private void OnRead(IAsyncResult ar)  
{  
    RecvItemObject item = (RecvItemObject)ar.AsyncState;  
    try  
    {  
        Stream stram = item.client.GetStram();  
        int readsize = stream.EndRead(ar);  
        item.current =+= readsize;  
        TotalReadSize += (uint)readsize;  
        if(item.current < item.total)  
        {  
            item.client.GetStram().BeginRead(ite.bufs,item.current,item.total - item.current,new AsyncCallback(OnRead)，item);  
        }  
        else  
        {  
            if(item.state == RecvItemObject.EndReadState.ReadHearder)  
            {  
                //上面就是讀取信息邏輯,數(shù)據(jù)在item.bufs里，自己按需求解析  
                //下面計(jì)算是否讀完包頭，下次應(yīng)該讀包還是包頭  
                if(true)  
                {  
                    item.client.GetStram().BeginRead(item.bufs,0,bufsSize,new AsyncCallback(this.OnRead),item);  
                }  
                else  
                {  
                    item.client.GetStram().BeginRead(item.bufs,0,dataLength,new AsyncCallback(this.OnRead),item);  
                }  

            }  
            else(item.state == RecvItemObject.EndReadState.ReadData)  
            {  
                //上面就是讀取信息邏輯  
                //下次應(yīng)該讀包頭  
                item.client.GetStram().BeginRead(item.bufs,0,bufsSize,new AsyncCallback(this.OnRead),item);  
            }  
        }  

    }  
}

可以看到，這種方式也就是一直通過(guò)調(diào)用異步加載函數(shù)AsyncCallback
來(lái)實(shí)現(xiàn)一直讀取信息
而上面用的的BeginRead()函數(shù)的最后一個(gè)參數(shù)item是自己定義的一個(gè)數(shù)據(jù)類(lèi)，函數(shù)的這個(gè)參數(shù)是用來(lái)下次異步回調(diào)的時(shí)候把上次的item傳給下個(gè)回調(diào)

private class RecvItemObject  
{  
    public enum EReadState  
    {  
        ReadData,  
        ReadHeader,  
    }  
    public byte[] bufs;  
    public int total;  
    public int current;  
    public EReadState state;  
    public TcpClient client;  
    public NetworkStram networkStream;  

    public RecvItemObject(TcpClient client, byte[] bufs,int total)  
    {  
        this.client = client;  
        this.bufs = bufs;  
        this.total = total;  
        current =0;  
        state = EReadState.ReadHeader;  

    }  
}

而寫(xiě)數(shù)據(jù)呢，是在游戲的Update里發(fā)送，加一條發(fā)送信息就在隊(duì)列里加一個(gè)，在Update里檢測(cè)如果隊(duì)列里有需要發(fā)送的數(shù)據(jù)就寫(xiě)數(shù)據(jù)

public void UpdateSend()  
{  
    //填寫(xiě)數(shù)據(jù)  
     try  
     {  
        NetworkStream stream = tcpCLient.getStream();  
        if(stream.CanWrite)  
        {  
            //pMsg數(shù)據(jù)Byte[]  
            stream.BeginWtrite(pMsg,0,pMsg.Length,new AsycCallback(this.OnWrite),tcpCLient);  
        }  

     }  
    catch(SocketException e)  
    {  
    }  
}

在發(fā)送完了以后會(huì)跑到上面的異步回掉OnWrite里。在里面把流關(guān)閉寫(xiě)入

private void OnWrite(IAsyncResult ar)  
{  
    TcpClient client = (TcpClient)ar.AsyncState;  
    try  
    {  
        client.GetStream().EndWrite(ar);  
    }  
    catch(SocketException e)  
    {  
    }  
}

另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)cdcxhl.cn，海內(nèi)外云服務(wù)器15元起步，三天無(wú)理由+7*72小時(shí)售后在線(xiàn)，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國(guó)服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡(jiǎn)單易用、服務(wù)可用性高、性?xún)r(jià)比高”等特點(diǎn)與優(yōu)勢(shì)，專(zhuān)為企業(yè)上云打造定制，能夠滿(mǎn)足用戶(hù)豐富、多元化的應(yīng)用場(chǎng)景需求。

分享題目：【小松教你手游開(kāi)發(fā)】【unity系統(tǒng)模塊開(kāi)發(fā)】unity網(wǎng)絡(luò)層讀寫(xiě)-創(chuàng)新互聯(lián)
標(biāo)題路徑：http://m.newbst.com/article16/ccjidg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供企業(yè)網(wǎng)站制作、網(wǎng)站策劃、虛擬主機(jī)、App設(shè)計(jì)、標(biāo)簽優(yōu)化、做網(wǎng)站

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶(hù)投稿、用戶(hù)轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話(huà)：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)