Cuni
10-09-2009, 10:05 AM
Làm chương trình phía Client
Trong ứng dụng này, chúng ta se thao tác với .Net Sockets. Chúng ta có 3 lớp chính là: TcpClient, TcpListener và NetworkStream. Trong đó, ứng dụng Listener luôn chạy đầu tiên bằng cách sử dụng phương thức start(): TcpListener.start(). Chúng ta sẽ viết ứng dụng TcpClient đầu tiên.
http://img501.imageshack.us/img501/7925/ungdungchatpictureib1.jpg
Đây là hàm có chức năng nhận tin nhắn:
public void ThreadProcReceive()
{
for (;;)
{
received = new byte[1024];
int readBytes = 0;
try
{
readBytes = tcp.GetStream().Read(received,0,received.Length);
}
catch (ObjectDisposedException) { return;
}
if (readBytes == 8)
{
StringBuilder shutMessage = new StringBuilder(8);
for (int count = 0; count < 8; count++)
{
char ch = (char)received[count];
shutMessage = shutMessage.Append(ch);
}
string shut = "shutdown";
string receivedMessage = shutMessage.ToString();
if (receivedMessage.Equals(shut))
{
MessageBox.Show(this,"Shutdown Request has arrived from the \nconnected party.\nYou cannot send message anymore.\nPlease close the window.","Shut down Request",MessageBoxButtons.OK,MessageBoxIcon.Information);
buttonSend.Enabled = false;
return;
}
}
StringBuilder str = new StringBuilder(1024);
for (int count = 0; count < readBytes; count++)
{
char ch = (char)received[count];
str = str.Append(ch);
str = str.Append(" ");
}
textBoxSendText.Text = str.ToString();
if (formClosing == true)
{
break;
}
}Đây là hàm xử lý sự kiện khi nhấn nút Connect:
private void buttonConnect_Click(object sender, System.EventArgs e)
{
textBoxIPAddress.Enabled = false;
IPAddress address = IPAddress.Parse(ipAddress);
tcp = new TcpClient((new IPEndPoint(Dns.Resolve(Dns.GetHostName()).AddressL ist[0],4002)));
LingerOption lingerOption = new LingerOption(false, 1);
tcp.LingerState = lingerOption;
tcp.Connect(new IPEndPoint(Dns.Resolve(ipAddress).AddressList[0],4001));
buttonSend.Enabled = true;
((Button)sender).Enabled = false;
receiveThread = new Thread(new ThreadStart(ThreadProcReceive));
receiveThread.Name = "Client's Receive Thread";
receiveThread.ApartmentState = ApartmentState.MTA;
receiveThread.Start();
}Đây là hàm xử lý sự kiện khi đóng Form1:
private void Form1_Closing(object sender, System.ComponentModel.CancelEventArgs e)
{
dataToSend = new byte[]{(byte)'s',(byte)'h',(byte)'u',(byte)'t',(byte)'d' ,(byte)'o',(byte)'w',(byte)'n'};
tcp.GetStream().Write(dataToSend,0,dataToSend.Leng th);
tcp.Close();
}
private void textBoxIPAddress_TextChanged(object sender, System.EventArgs e)
{
ipAddress = textBoxIPAddress.Text;
}Đây là hàm xử lý sự kiện khi nhấn nút Send:
private void buttonSend_Click(object sender, System.EventArgs e)
{
if (textBoxDataToSend.Text.Length != 0)
{
char[] charArray = textBoxDataToSend.Text.ToCharArray(0,textBoxDataTo Send.Text.Length);
dataToSend = new byte[textBoxDataToSend.Text.Length];
for (int charCount = 0; charCount < textBoxDataToSend.Text.Length; charCount++)
{
dataToSend[charCount] = (byte)charArray[charCount];
}
}
else
{
dataToSend = new byte[]{(byte)'e',(byte)'m',(byte)'p',(byte)'t',(byte)'y' };
}
tcp.GetStream().Write(dataToSend,0,dataToSend.Leng th);
textBoxDataToSend.Text = "";
}
Download mã nguồn:
http://www.mediafire.com/?dyymmmizmmm
Trong ứng dụng này, chúng ta se thao tác với .Net Sockets. Chúng ta có 3 lớp chính là: TcpClient, TcpListener và NetworkStream. Trong đó, ứng dụng Listener luôn chạy đầu tiên bằng cách sử dụng phương thức start(): TcpListener.start(). Chúng ta sẽ viết ứng dụng TcpClient đầu tiên.
http://img501.imageshack.us/img501/7925/ungdungchatpictureib1.jpg
Đây là hàm có chức năng nhận tin nhắn:
public void ThreadProcReceive()
{
for (;;)
{
received = new byte[1024];
int readBytes = 0;
try
{
readBytes = tcp.GetStream().Read(received,0,received.Length);
}
catch (ObjectDisposedException) { return;
}
if (readBytes == 8)
{
StringBuilder shutMessage = new StringBuilder(8);
for (int count = 0; count < 8; count++)
{
char ch = (char)received[count];
shutMessage = shutMessage.Append(ch);
}
string shut = "shutdown";
string receivedMessage = shutMessage.ToString();
if (receivedMessage.Equals(shut))
{
MessageBox.Show(this,"Shutdown Request has arrived from the \nconnected party.\nYou cannot send message anymore.\nPlease close the window.","Shut down Request",MessageBoxButtons.OK,MessageBoxIcon.Information);
buttonSend.Enabled = false;
return;
}
}
StringBuilder str = new StringBuilder(1024);
for (int count = 0; count < readBytes; count++)
{
char ch = (char)received[count];
str = str.Append(ch);
str = str.Append(" ");
}
textBoxSendText.Text = str.ToString();
if (formClosing == true)
{
break;
}
}Đây là hàm xử lý sự kiện khi nhấn nút Connect:
private void buttonConnect_Click(object sender, System.EventArgs e)
{
textBoxIPAddress.Enabled = false;
IPAddress address = IPAddress.Parse(ipAddress);
tcp = new TcpClient((new IPEndPoint(Dns.Resolve(Dns.GetHostName()).AddressL ist[0],4002)));
LingerOption lingerOption = new LingerOption(false, 1);
tcp.LingerState = lingerOption;
tcp.Connect(new IPEndPoint(Dns.Resolve(ipAddress).AddressList[0],4001));
buttonSend.Enabled = true;
((Button)sender).Enabled = false;
receiveThread = new Thread(new ThreadStart(ThreadProcReceive));
receiveThread.Name = "Client's Receive Thread";
receiveThread.ApartmentState = ApartmentState.MTA;
receiveThread.Start();
}Đây là hàm xử lý sự kiện khi đóng Form1:
private void Form1_Closing(object sender, System.ComponentModel.CancelEventArgs e)
{
dataToSend = new byte[]{(byte)'s',(byte)'h',(byte)'u',(byte)'t',(byte)'d' ,(byte)'o',(byte)'w',(byte)'n'};
tcp.GetStream().Write(dataToSend,0,dataToSend.Leng th);
tcp.Close();
}
private void textBoxIPAddress_TextChanged(object sender, System.EventArgs e)
{
ipAddress = textBoxIPAddress.Text;
}Đây là hàm xử lý sự kiện khi nhấn nút Send:
private void buttonSend_Click(object sender, System.EventArgs e)
{
if (textBoxDataToSend.Text.Length != 0)
{
char[] charArray = textBoxDataToSend.Text.ToCharArray(0,textBoxDataTo Send.Text.Length);
dataToSend = new byte[textBoxDataToSend.Text.Length];
for (int charCount = 0; charCount < textBoxDataToSend.Text.Length; charCount++)
{
dataToSend[charCount] = (byte)charArray[charCount];
}
}
else
{
dataToSend = new byte[]{(byte)'e',(byte)'m',(byte)'p',(byte)'t',(byte)'y' };
}
tcp.GetStream().Write(dataToSend,0,dataToSend.Leng th);
textBoxDataToSend.Text = "";
}
Download mã nguồn:
http://www.mediafire.com/?dyymmmizmmm