五子棋小游戏(2)

为了在局域网中玩，现在完成网络通信部分。采用的是udp连接，跟界面之间的交换通过event通信

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Text.RegularExpressions;
using System.Diagnostics;

namespace Chess5
{
public class NetOp
{
#region 构造函数，析构函数
public NetOp()
{
while (checkPortValid(udpPort))
udpPort++;
}

~NetOp()
{
if (server != null)
server.Close();
if (client != null)
client.Close();
server = null;
client = null;
}
#endregion

#region 静态变量
static UdpClient server = null;
static UdpClient client = null;
#endregion

#region 字段
private int udpPort = 9000;
private Thread t;
#endregion

#region 事件
public event VoidTwoStringDelegate startGame;
public event VoidTwoStringDelegate endGame;
public event VoidOneStringTwoIntDelegate chess;
public event VoidTwoStringDelegate winGame;
#endregion

#region 私有函数
private bool checkPortValid(int port)
{
bool bTaken = false;
Process pro = new Process();
// 设置命令行、参数
pro.StartInfo.FileName = "cmd.exe";
pro.StartInfo.UseShellExecute = false;
pro.StartInfo.RedirectStandardInput = true;
pro.StartInfo.RedirectStandardOutput = true;
pro.StartInfo.RedirectStandardError = true;
pro.StartInfo.CreateNoWindow = true;
// 启动CMD
pro.Start();
// 运行端口检查命令
pro.StandardInput.WriteLine("netstat -a -p UDP");
pro.StandardInput.WriteLine("exit");
// 获取结果
string line = null;
while ((line = pro.StandardOutput.ReadLine()) != null)
{
line = line.Trim();
if (line.Contains(":" + port + " "))
{
bTaken = true;
break;
}
}
pro.Close();
return bTaken;
}

private void beginUDPListen()
{
try
{
server = new UdpClient(udpPort, AddressFamily.InterNetwork);
IPEndPoint udpSender = new IPEndPoint(IPAddress.Any, 0);
while (true)
{
byte[] udpData = server.Receive(ref udpSender);
string strudpData = Encoding.Default.GetString(udpData, 0, udpData.Length);
analyzeUdpData(strudpData);
}
}
catch (Exception e)
{
analyzeUdpData("Fatal Error: " + e.Message);
}
}

private void analyzeUdpData(string udpData)
{
string[] temp = udpData.Split(' ');
if (udpData.StartsWith("startGame:"))
{
if (startGame != null)
startGame(temp[1], temp[2]);
}
else if (udpData.StartsWith("endGame:"))
{
if (endGame != null)
endGame(temp[1], temp[2]);
}
else if (udpData.StartsWith("chess:"))
{
if (chess != null)
chess(temp[1], int.Parse(temp[2]), int.Parse(temp[3]));
}
else if (udpData.StartsWith("winGame:"))
{
if (winGame != null)
winGame(temp[1], temp[2]);
}
else
{
Msg.ShowInfo(udpData);
}
}

#endregion

#region 公开函数
public void StartListen()
{
t = new Thread(new ThreadStart(beginUDPListen));
t.Start();
}

public void endListen()
{
if (t != null)
{
t.Abort();
t = null;
}
if (server != null)
server.Close();
if (client != null)
client.Close();
server = null;
client = null;
}

public string sendUdp(string strUdpSendData, string targetUdpIp)
{
byte[] udpSendData = Encoding.Default.GetBytes(strUdpSendData);
IPAddress ipUDP;
if (checkIPFormat(targetUdpIp, out ipUDP))
{
try
{
IPEndPoint udpTarget = new IPEndPoint(ipUDP, udpPort);
client = new UdpClient(65534);
client.Connect(ipUDP, udpPort);
client.Send(udpSendData, udpSendData.Length);
client.Connect(ipUDP, udpPort + 1);
client.Send(udpSendData, udpSendData.Length);
client.Connect(ipUDP, udpPort - 1);
client.Send(udpSendData, udpSendData.Length);
client.Connect(ipUDP, udpPort + 2);
client.Send(udpSendData, udpSendData.Length);
client.Connect(ipUDP, udpPort - 2);
client.Send(udpSendData, udpSendData.Length);
client.Close();
}
catch (Exception)
{
analyzeUdpData("Fail to send UDP packet");
}
finally
{
if (client != null)
{
client.Close();
}
}
return "";
}
else
return "IP格式错误";
}

public bool checkIPFormat(string strIP, out IPAddress ipTCP)
{
ipTCP = IPAddress.None;
try
{
ipTCP = IPAddress.Parse(strIP);
}
catch (Exception)
{
return false;
}
string formatIP = @"^\d{1,3}\.\d{1,3}\.\d{1,3}\.\d{1,3}$";
Match regExIP = System.Text.RegularExpressions.Regex.Match(strIP, formatIP);
if (regExIP.Success)
{
string[] strIPNums = strIP.Split('.');
foreach (string strIPNum in strIPNums)
{
if (int.Parse(strIPNum) >= 255 || int.Parse(strIPNum) < 0)
return false;
}
return true;
}
else
return false;
}
#endregion
}
}