[c#]总结异步连接socekt

I hear and I forget. I see and I remember. I do and I understand.

关键字：BeginConnect, IAsyncResult

1.关键点总结

• c#中socket进行异步连接，使用socket.BeginConnect(),返回一个异步操作的结果，记录了当前操作的状态。
  BeginConnect()之后，系统会使用一个特殊的线程进行网络连接操作。操作完成后，调用回调函数。

举例其中一个异步连接方法的参数作为说明:
IAsyncResult BeginConnect(EndPoint endpoint,AsyncCallback callback,Object state):

IAsyncResult : 进行异步的socket连接的操作状态。
IAsyncResult.AsyncState 为BeginConnect中传入的state
IAsyncResult.IsCompleted 标识操作是否完成。(和是否连接成功没有关系)
IAsyncResult.AsyncWaitHandle 返回一个WaitHandler，用于设置信号量,等待一定时间之后，返回操作是否完成。(阻塞线程)

AsyncCallback callback:异步连接操作完成之后，调用的回调。

Object state: 应该传入一个socket,以记录当前socket的连接情况。

• 使用BeginConnect之后，在操作结果的回调中，需要调用EndConnect()方法以完成连接。

• 连接操作在连接成功或者连接异常之后结束。

• 如果socket开始连接一个没有监听的ip和端口,或者网络情况有波动的时候，默认的连接超时时间很久。这个时候，可以使用IAsyncResult和IAsyncResult.AsyncWaitHandle来手动在一定时间内提前结束socket.(实验的时候，如果连接的时候本地ip,即使没有监听，也会很快完成连接操作。因此，实验的时候要连接一个其他ip)

• 关于Socket的一些方法：
  Socket.Connected : 是否与远程host连接。(UDP永远返回true)
  Socket.Available : 可以读取的数据(从网络中接收的数据)的数量
  Socket.ShutDown : 关闭Socekt的发送和接收数据功能。面向连接的连接中，在Close之前调用可以保证所有的数据都被发送和接收了。
  Socket.Close() : 关闭socket连接，并且释放所有关联的资源。
  Socket.Close(Int32 timeout) : 设置一个timeout时间以使得发送队列中的数据可以被发送。之后关闭socket连接，并且释放所有关联的资源

  socket.ShutDown(SocketShutdown.Both);
  socket.Close();

2.示例代码：

1.客户端c#代码

using System.Collections.Generic;
using System.Net.Sockets;
using System.Net;
using System;
using System.Threading;
using UnityEngine;
namespace Yanchezuo
{
    public class TcpSocketConnect:IDisposable
    {
        private Socket _socket;
        private IPAddress iPAddress;
        private IPEndPoint iPEndPoint;

        public TcpSocketConnect()
        {
            iPAddress = IPAddress.Parse("192.168.1.169");
            iPEndPoint = new IPEndPoint(iPAddress, 12345);
        }

        public void Connect()
        {
            Disconnect();
            _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IAsyncResult rs = null;
            try
            {
                _socket.ReceiveTimeout = 15 * 1000;
                _socket.SendTimeout = 10 * 1000;
                rs = _socket.BeginConnect(iPEndPoint, ConnectResult, _socket);
            }
            catch (Exception e)
            {
                Debug.Log("beginConnect exception....");
            }
            Thread thread = new Thread(OnCancelConnect);
            thread.Start(rs);

        }
        private void ConnectResult(IAsyncResult ar)
        {
            Debug.Log("ConnectResult---------");
            if (ar.AsyncState != null)
            {
                // 这里的ar.AsyncState就是_socket
                Socket s = ar.AsyncState as Socket;
                Debug.Log("ar.AsyncState socket---Connected------" + s.Connected);
                // 结束连接操作
                s.EndConnect(ar);
                if (s.Connected)        // 连接成功的操作
                {
                }
                else                    // 连接失败的操作
                {
                }
            }
        }

        private void OnCancelConnect(object obj)
        {
            IAsyncResult result = obj as IAsyncResult;
            try
            {
                // 等待2*1000ms之后，如果连接操作还没有完成，就手动关闭socket
                if (result != null && !result.AsyncWaitHandle.WaitOne(2*1000, true))
                {
                    Debug.Log("manul CancelConnect----");
                    if (_socket != null)
                    {
                        _socket.Close();
                    }
                    _socket = null;
                }
            }
            catch (Exception ex)
            {
                Debug.Log("onCancelConnect exception............");
            }
        }

        public void Disconnect()
        {
            if (_socket != null)
            {
                if (_socket.Connected)
                {
                    _socket.Shutdown(SocketShutdown.Both);
                    _socket.Disconnect(false);

                    Debug.Log("Disconnect socket---aviliable------" + _socket.Available);
                }
                _socket.Close(0);
                Debug.Log("socket set null");
                _socket = null;
            }
            else
            {
                Debug.Log("Disconnect socket,but _socket==null");
            }
        }

        public void Dispose()
        {
            Disconnect();
        }
    }
}

2.服务端python代码

# -*- coding:utf-8 -*-
import socket

s=socket.socket()
hostname=socket.gethostname()
hostip=socket.gethostbyname(hostname)
port=12345
print hostname+",ip:"+hostip
# s.bind((host,port))
s.bind((hostip,port))
s.listen(2)

print 'listening...'
while True:
    c,addr=s.accept()
    c.send('connect ok')
    print 'accept -- :',addr
#     c.close()

转载请注明作者及出处,本文作者为延澈左,本文标题为[c#]总结异步连接socekt 本文链接为https://yanchezuo.com/csharp-2.html

赏

谢谢你的支持~~