学习C# ，写了一个可以联网对战的五子棋小游戏。
完整源代码地址：https://files.cnblogs.com/fmnisme/%E4%BA%94%E5%AD%90%E6%A3%8B2.rar
废话不多说，贴上代码。
using:
using System;
using System.Collections.Generic;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;
全局变量：
int[,] chessArr; //存储棋格中棋子的状态，列如chessArr[4,5]=0;表示第5行，第6列的交叉点是黑子。此外1代表白子，2代表空。
bool black = true; //是否到黑子下棋。
int num = 15; //棋盘的大小：num*num
ControlInternet CI = new ControlInternet(); //实例化的联网对战类。
bool over = true; //是否结束，结束则定制落子。
bool internetFight = false; //该值为true时则为联网对战，此时black变量是固定的，一方为黑，一方为白。
List<PictureBox> picBoxList = new List<PictureBox>(); //使用PictureBox作为棋格。
bool put=true; //单机游戏时该值永远为true，联网时接收到数据设为true，发送数据后设为false。
画棋格
//棋格初始化
private void main_Load(object sender, EventArgs e)
{
drawCheckerboar();
}
//画棋格
public void drawCheckerboar()
{
chessArr = new int[num, num];
int currentPoint = 0;
int chessLength = 30;
int initX = 10;
int initY = 10;
int _x = initX;
int _y = initY;
PictureBox tmpBox;
for (int x = 0; x < num * num; x++)
{
if (currentPoint % num == 0)
{
_x = initX;
_y = ((int)currentPoint / num) * chessLength + initY;
}
else
{
_x += chessLength;
}
tmpBox = new PictureBox();
tmpBox.Left = _x;
tmpBox.Top = _y;
tmpBox.Width = chessLength;
tmpBox.Height = chessLength;
tmpBox.Image = global::五子棋2.Properties.Resources.gezi;
tmpBox.Name = (currentPoint % num).ToString() + "-" + ((int)currentPoint / num).ToString(); //x-y
chessArr[currentPoint % num, (int)currentPoint / num] = 2;
tmpBox.Click += new EventHandler(pic_click);
picBoxList.Add(tmpBox);
this.Controls.Add(tmpBox);
tmpBox = null;
currentPoint++;
}
}
单机棋格时判断落子，以及是否胜利。
//单击棋格
private void pic_click(object sender,EventArgs e)
{
PictureBox pb = (PictureBox)sender;
string[] stringArr = pb.Name.Split('-');
int[] intArr = new int[] { int.Parse(stringArr[0]),int.Parse(stringArr[1])};
if (chessArr[intArr[0],intArr[1]]==2&&!over&&put)
{
if (black)
{
pb.Image = global::五子棋2.Properties.Resources.black;
chessArr[intArr[0], intArr[1]] = 0;
if (!internetFight)
black = false;
else
{
CI.sendMsg(00,0,(intArr[0]+intArr[1]*num).ToString());
put = false;
}
if (win(0))
{
over = true;
MessageBox.Show("black win!");
}
}
else
{
pb.Image = global::五子棋2.Properties.Resources.white;
chessArr[intArr[0], intArr[1]] = 1;
if (!internetFight)
black = true;
else
{
CI.sendMsg(00, 1, (intArr[0] + intArr[1] * num).ToString());
put = false;
}
if (win(1))
{
over = true;
MessageBox.Show("white win!");
}
}
}
}
//是否胜利。
private bool win(int flag)
{
int checkPoint = 0;
int _x = 0;
int _y = 0;
//横着检查。
for (int x = 0; x < num*num;x++ )
{
int consecutive = 0;
checkPoint = x;
for (int y = 0; y < 5; y++)
{
_x = (checkPoint +y)% num;
_y = (int)checkPoint / num;
if (checkPoint > (num * num - 1) || _x > num-1)
break;
if(chessArr[_x,_y]==flag)
{
consecutive++;
}
//checkPoint++;
}
if (consecutive == 5)
return true;
}
//竖着检查
for (int x = 0; x < num * num; x++)
{
int consecutive = 0;
checkPoint = x;
for (int y = 0; y < 5; y++)
{
_x = (checkPoint +y)% num;
_y = (int)checkPoint/ num;
if (checkPoint > (num * num - 1) || _x > num - 1)
break;
if (chessArr[ _y,_x] == flag)
{
consecutive++;
}
//checkPoint++;
}
if (consecutive == 5)
return true;
}
//正斜
for (int x = 0; x < num * num; x++)
{
int consecutive = 0;
checkPoint = x;
for (int y = 0; y < 5; y++)
{
_x = checkPoint % num + y;
_y = ((int)checkPoint / num) + y;
if (_x > num - 1 || _y > num-1)
break;
if (chessArr[_x, _y] == flag)
{
consecutive++;
}
}
if (consecutive == 5)
return true;
}
//反斜
for (int x = 0; x < num * num; x++)
{
int consecutive = 0;
checkPoint = x;
for (int y = 0; y < 5; y++)
{
_x = checkPoint % num - y;
_y = (int)checkPoint / num +y;
if (_x > num - 1 || _x < 0 || _y > num - 1 || _y < 0)
break;
if (chessArr[_x, _y] == flag)
{
consecutive++;
}
}
if (consecutive == 5)
return true;
}
return false;
}
连接，监听函数
//监听按钮,等待其它程序连接。
private void btn_listen_Click(object sender, EventArgs e)
{
Thread listenThread = new Thread(new ThreadStart(listen));
listenThread.Start();
}
//监听函数
private void listen()
{
try
{
Thread.CurrentThread.IsBackground = true;
Control.CheckForIllegalCrossThreadCalls = false;
btn_connect.Enabled = false;
btn_listen.Enabled = false;
txt_ip.Enabled = false;
CI.listen();
over = false; //连接后才允许落子。
internetFight = true;
CI.OnReceiveMsg += new ChessEventHander(manageChessEvent);
}
catch (Exception ex)
{
txt_talk.Text += "listen:\r\n" + ex.Message+"\r\n";
}
}
//连接按钮，连接在监听的程序。
private void btn_connect_Click(object sender, EventArgs e)
{
try
{
CI.connect(txt_ip.Text);
over = false;
black = false;
internetFight = true;
CI.OnReceiveMsg += new ChessEventHander(manageChessEvent);
btn_connect.Enabled = false;
btn_listen.Enabled = false;
txt_ip.Enabled = false;
}
catch (Exception ex)
{
txt_talk.Text +="btn_connect_Click:\r\n"+ ex.Message + "\r\n";
}
}
//发送消息
private void btn_sendMsg_Click(object sender, EventArgs e)
{
try
{
string player;
if (black == true)
player = "黑子玩家：\r\n";
else
player = "白子玩家：\r\n";
CI.sendMsg(1, 0, player + txt_send.Text);
txt_talk.Text += player + txt_send.Text + "\r\n";
txt_send.Text = "";
}
catch (Exception ex)
{
txt_talk.Text += "btn_sendMsg_Click:\r\n" + ex.Message+"\r\n";
}
}
//处理接收信息事件。
public void manageChessEvent(object sender, ChessEvent e)
{
Control.CheckForIllegalCrossThreadCalls = false;
switch (e.Iclass)
{
case "0": //棋子信息。
int _x = int.Parse(e.content) % num;
int _y = (int)(int.Parse(e.content) / num);
chessArr[_x, _y] = int.Parse(e.flag);
if (e.flag == "0")
{
picBoxList[int.Parse(e.content)].Image = global::五子棋2.Properties.Resources.black;
if (win(0))
{
over = true;
MessageBox.Show("black Win");
}
}
else
{
picBoxList[int.Parse(e.content)].Image = global::五子棋2.Properties.Resources.white;
if (win(1))
{
over = true;
MessageBox.Show("white win");
}
}
put = true;
break;
case "1": //聊天
txt_talk.Text += e.content + "\r\n";
break;
case "2": //重新开始。
restartGmae();
break;
case"5":
stopConnect();
break;
}
}
private void btn_stopConnect_Click(object sender, EventArgs e)
{
CI.sendMsg(5, 0, "000");
CI = new ControlInternet();
stopConnect();
}
//自定义消息函数
public class ChessEvent : EventArgs
{
public string Iclass;
public string content;
public string flag;
public ChessEvent(string _class, string _flag, string _content)
{
Iclass = _class;
content = _content;
flag = _flag;
}
}
//委托
public delegate void ChessEventHander(object sender,ChessEvent e);
//联网对战接口。
public interface ISocket
{
void listen();
void connect(string ipStr);
void sendMsg(byte @class,byte flag,string content);
void receiveMsg(object obj);
void close();
//event OnReceiveMsg();
}
//联网对战类。
public class ControlInternet:ISocket
{
private Socket skRec = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
private IPEndPoint ipeRec;
private Socket skSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
private IPEndPoint ipeSend;
public event ChessEventHander OnReceiveMsg;
public ControlInternet()
{
}
public void listen()
{
try
{
IPAddress myIp = Dns.GetHostEntry(Dns.GetHostName()).AddressList[1];
skRec.Bind(new IPEndPoint(IPAddress.Parse(myIp.ToString()), 8880));
skRec.Listen(0);
Socket clientRec = skRec.Accept();
Thread receiveMsgThread = new Thread(new ParameterizedThreadStart(receiveMsg));
receiveMsgThread.Start(clientRec);
skSend.Bind(new IPEndPoint(IPAddress.Parse(myIp.ToString()), 8881));
skSend.Listen(0);
skSend = skSend.Accept();
}
catch (Exception ex)
{
MessageBox.Show("listen:"+ex.Message);
}
}
public void connect(string ipStr)
{
ipeSend = new IPEndPoint(IPAddress.Parse(ipStr), 8880);
skSend.Connect(ipeSend);
ipeRec = new IPEndPoint(IPAddress.Parse(ipStr), 8881);
skRec.Connect(ipeRec);
Thread receiveMsgThread = new Thread(new ParameterizedThreadStart(receiveMsg));
receiveMsgThread.Start(skRec);
}
public void sendMsg(byte @class,byte flag,string content)
{
try
{
byte[] tmpBytes = Encoding.Default.GetBytes(content);
MessageControl.Message msg = new MessageControl.Message(@class, flag, tmpBytes);
byte[] sendeBytes = msg.ToBytes();
skSend.Send(sendeBytes);
}
catch (Exception ex)
{
}
}
public void receiveMsg(object obj)
{
Thread.CurrentThread.IsBackground = true;
Socket clientRec = (Socket)obj;
MessageControl.Message msg = new MessageControl.Message();
MessageControl.MessageStream mst = new MessageControl.MessageStream();
int revb;
try
{
while (clientRec.Connected)
{
byte[] recBytes = new byte[512];
revb = clientRec.Receive(recBytes);
mst.Write(recBytes, 0, revb);
if (mst.Read(out msg))
{
OnReceiveMsg(this, new ChessEvent(msg.Class.ToString(), msg.Flag.ToString(), Encoding.Default.GetString(msg.Content)));
}
}
}
catch (Exception ex)
{
//skRec.Close();
//skSend.Close();
//clientRec.Close();
}
}
public void close()
{
skRec.Close();
skSend.Close();
// //skRec = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
// //skSend = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
}
~ControlInternet()
{
skRec.Close();
skSend.Close();
}
}