Question

C# TCPClient/TCPListener 编程

本人想实现 一个 C/S 结构的 简单功能.

但是头绪比较乱,想高人帮忙指点一下.

服务器端:
程序开始运行时,5秒后(看完客户端的功能,您就能知道这5秒什么意思)开始40秒的倒计时.当倒计到期(为0)时.便向所有已连接的客户端发送字符串"1".然后开始下一次的(5)+40秒倒计时,如此循环.

客户端:
程序开始运行时,检测服务器端的倒计时状态.

如果服务器端还没进入倒计时状态(也就是还处在倒计时前5秒的状态中),则让客户端进入.

如果服务器端已经进入倒计时状态.则弹出对话框让用户等待(等到下一次循环前的那5秒中再自动进入).....

客户端界面:

2个 label 控件.

一个用来显示服务器端倒计时的时间(如服务器倒计时到了39,则label1.text = "39",服务器到了38,则label1.text="38"..以此类推).

当服务器倒计时结束.
所有已连接的客户端的label2.text = 服务器返回过来的那个字符串"1".

提供详细的代码,以及说明文档.本人将追加分数.
服务器利用Timer 间隔1秒 倒计时时间 -1

客户端则 也就是label1.text = string.format("{0}", int.parse(label1.text) - 1);

注意我不需要客户端自己拥有倒计时的功能.

而是服务器端 拥有 40秒 每一秒钟 -1 并发送给所有客户端结果的功能.

也就是说 客户端上的数据 完全是由服务器端发送过来的....

Answer 1

1、叙述有点问题：客户端必须先尝试连接，并且不能操作员手工连接，因为不知道服务器的状态，所以客户端有一个定时连接尝试的timer，当然并非倒计时的Timer。
另外一个问题：数据包可能丢失，所以服务器告诉客户端每次-1的做法不可靠，应该是发给客户端当前的秒数。
2、代码：卖过几千元钱的啊
（1) 客户端：
public partial class Form1 : Form
{
Socket clientSock ;//连接服务器的客户端Socket
IPAddress serverIp = IPAddress.Parse("127.0.0.1");
int port = 8000;
Thread thread;//接收数据的线程

delegate void SetReceivedToLabelCallBack(string msg,bool isSeconds);//数据接收线程到窗体的跨线程调用委托

public Form1()
{
InitializeComponent();
}

private void Form1_Load(object sender, EventArgs e)
{
try
{
linkToServer();//连接服务器
}
catch (Exception ec)
{
MessageBox.Show(ec.Message+",每隔1秒会自动再试");
timerTryLinkToServer.Enabled = true;
}
}

private void timerTryLinkToServer_Tick(object sender, EventArgs e)
{
try
{
linkToServer();
timerTryLinkToServer.Enabled = false;
}
catch { }//不再提示，否则每秒一次，够烦
}

private void linkToServer()
{
try
{
IPEndPoint serverRemote = new IPEndPoint(serverIp, port);
clientSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
clientSock.Connect(serverRemote);

thread = new Thread(new ThreadStart(receiveThread));
thread.Start();
MessageBox.Show("linked");
}
catch (Exception e)
{
MessageBox.Show(e.Message);
}
}

private void receiveThread()
{
try
{
while (true)
{
byte[] buffer = new byte[8];
int receivedBytesCount=clientSock.Receive(buffer);
string receivedStr = System.Text.Encoding.Unicode.GetString(buffer);
if (receivedBytesCount == 4)//发来的是4字节int数据
{
DisplayReceivedMsg(receivedStr,true);
}
else//发来的是字符串“1”，非4字节
{
DisplayReceivedMsg(receivedStr,false);
}
}
}
catch(Exception ec)
{
MessageBox.Show(ec.Message);
}
}

public void DisplayReceivedMsg(string msg,bool isSeconds)
{
Label label=null;
if (isSeconds)
{
label = label1;
}
else
{
label = label2;
}

if (label.InvokeRequired)//如果是跨线程调用
{
SetReceivedToLabelCallBack d = new SetReceivedToLabelCallBack(DisplayReceivedMsg);
this.Invoke(d, new object[] { msg,isSeconds });
}
else
{
label.Text = msg;
}
}
//好习惯，关闭套接字
private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
if (thread != null)
{
thread.Abort();
thread = null;
}
if (clientSock != null)
{
clientSock.Close();
clientSock = null;
}
}

}
（2）服务器端：
public partial class Form1 : Form
{
public Form1()
{
InitializeComponent();
}

IPAddress serverIp = IPAddress.Parse("127.0.0.1");
int port = 8000;
Socket listenSock;

ArrayList clientSockets = new ArrayList();//保存客户端连接的Socket
System.Timers.Timer timer = new System.Timers.Timer();

int seconds = 0;
bool blockSocket=false;//是否停止监听（不接受客户）
Thread thListen;//监听线程

private void Form1_Load(object sender, EventArgs e)
{
IPEndPoint local = new IPEndPoint(serverIp, port);
listenSock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
listenSock.Bind(local);
listenSock.Listen(50);

if (listenStart())
{
timer.Interval = 1000;
timer.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed);
timer.Enabled = true;
}
}

void timer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
{
seconds++;
if (seconds==5)
{
listenStop();
MessageBox.Show("Stop");
return;
}
if(seconds==45)
{
if (listenStart())
MessageBox.Show("Start");
else MessageBox.Show("startError");

send("1");
seconds = 0;
return;
}
if(seconds<45 && seconds>5)
{
send((45 - seconds).ToString());
}
}

private void listenStop()
{
try
{
blockSocket = true;
if (thListen != null)
{
thListen.Abort();
thListen = null;
}
}
catch (Exception e)
{
MessageBox.Show(e.Message);
}
}

private bool listenStart()
{
try
{
thListen = new Thread(new ThreadStart(listenThread));
thListen.Start();
return true;
}
catch (Exception ec)
{
MessageBox.Show(ec.Message);
return false;
}
}

private void listenThread()
{
try
{
while (!blockSocket)
{
Socket sock = listenSock.Accept();
if (clientSockets.IndexOf(sock) < 0)
{
clientSockets.Add(sock);
MessageBox.Show("built one");
}
}
}
catch (Exception e)
{
MessageBox.Show(e.Message);
}
}

private void send(string msg)
{
foreach (Socket sock in clientSockets)
{
try
{
byte[] buffer = System.Text.Encoding.Unicode.GetBytes(msg);
sock.SendTimeout = 500;
sock.Send(buffer);
MessageBox.Show("send "+msg);
}
catch (Exception ec)
{
MessageBox.Show(ec.Message);
}
}
}

private void Form1_FormClosing(object sender, FormClosingEventArgs e)
{
if (thListen!= null)
{
thListen.Abort();
thListen = null;
}
if (listenSock != null)
{
listenSock.Close();
listenSock = null;
}
for (int i = 0; i < clientSockets.Count; i++)
{
Socket sock = (Socket)clientSockets[i];
sock.Close();
}
}
}
****************************
楼主没有诚意,这么长时间还不结帖啊。

Answer 2

不知道以上的答案能不能使楼主满意呢？

Answer 3

汗。。。。。。。有难度！！！

Answer 4

很好！