73 lines
3.5 KiB
C#
73 lines
3.5 KiB
C#
using Polly;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Net.Sockets;
|
|
using System.Net;
|
|
using System.Runtime.InteropServices;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
using DM_Weight.Models;
|
|
using DM_Weight.ViewModels;
|
|
using log4net;
|
|
|
|
namespace DM_Weight.Port
|
|
{
|
|
public class KeepAliveSocket
|
|
{
|
|
/// <summary>
|
|
/// 生成带有心跳检测的socket
|
|
/// </summary>
|
|
public class KeepALiveSocket
|
|
{
|
|
|
|
private static ILog socketLogger = LogManager.GetLogger(typeof(CheckOrderNewWindowViewModel));
|
|
public static Socket MakeKeepALiveSocket(string ip, int port)
|
|
{
|
|
uint dummy = 0;
|
|
byte[] inOptionValues = new byte[Marshal.SizeOf(dummy) * 3];
|
|
BitConverter.GetBytes((uint)1).CopyTo(inOptionValues, 0);//启用Keep-Alive
|
|
BitConverter.GetBytes((uint)10000).CopyTo(inOptionValues, Marshal.SizeOf(dummy));//在这个时间间隔内没有数据交互，则发送探测包
|
|
BitConverter.GetBytes((uint)10000).CopyTo(inOptionValues, Marshal.SizeOf(dummy) * 2);//发探测包时间间隔
|
|
IPEndPoint iep = new IPEndPoint(IPAddress.Parse(ip), port);
|
|
Socket _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
|
_socket = Policy.Handle<Exception>()
|
|
.Retry(3, (exception, retryCount) => {
|
|
socketLogger.Info($"建立Socket,第{retryCount}次重试", exception);
|
|
// return TimeSpan.FromSeconds (1);
|
|
})
|
|
.Execute<Socket>(() => {
|
|
_socket.IOControl(IOControlCode.KeepAliveValues, inOptionValues, null);
|
|
_socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);
|
|
_socket.BeginConnect(iep,null,null);
|
|
return _socket;
|
|
});
|
|
return _socket;
|
|
}
|
|
public static Socket MakeKeepALiveSocket(IpAndPort ipAndPort)
|
|
{
|
|
uint dummy = 0;
|
|
byte[] inOptionValues = new byte[Marshal.SizeOf(dummy) * 3];
|
|
BitConverter.GetBytes((uint)1).CopyTo(inOptionValues, 0);//启用Keep-Alive
|
|
BitConverter.GetBytes((uint)10000).CopyTo(inOptionValues, Marshal.SizeOf(dummy));//在这个时间间隔内没有数据交互，则发送探测包
|
|
BitConverter.GetBytes((uint)10000).CopyTo(inOptionValues, Marshal.SizeOf(dummy) * 2);//发探测包时间间隔
|
|
IPEndPoint iep = new IPEndPoint(IPAddress.Parse(ipAndPort.Ip), ipAndPort.Port);
|
|
Socket _socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
|
_socket = Policy.Handle<Exception>()
|
|
.Retry(3, (exception, retryCount) => {
|
|
socketLogger.Info($"建立Socket,第{retryCount}次重试", exception);
|
|
// return TimeSpan.FromSeconds (1);
|
|
})
|
|
.Execute<Socket>(() => {
|
|
_socket.IOControl(IOControlCode.KeepAliveValues, inOptionValues, null);
|
|
_socket.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.KeepAlive, true);
|
|
_socket.Connect(iep);
|
|
return _socket;
|
|
});
|
|
return _socket;
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|