Contoh program berikut mengimplementasikan komunikasi Socket sederhana dan dapat membuka banyak klien. Tes lokal lulus, tetapi tes online tidak dilakukan.
Server:
menggunakan System.Net;
menggunakan System.Net.Sockets;
menggunakan System.Threading
menggunakan System.Collections;
namespace MySocketServer1
{
public parsial class Form1 : Form
{
private IPAddress serverIP = IPAddress.Parse("127.0.0.1");//Gunakan mesin ini untuk menguji
server IPEndPoint pribadiFullAddr;//Alamat terminal lengkap
private Socket sock
private System.Timers. Timer myTimer;
private ArrayList alSock;//Digunakan untuk menyimpan koneksi ketika beberapa koneksi dibuat
Formulir publik1()
{
InisialisasiKomponen()
;
private void btStart_Click(pengirim objek, EventArgs e)
{
serverFullAddr = new IPEndPoint(serverIP, 1000); //Dapatkan nomor port 1000
//Bangun objek Socket, jenis soketnya adalah "stream socket", tentukan lima tupel. elemen protokol
sock = new Socket(AddressFamily.InterNetwork, SocketType.Stream,
ProtocolType.Tcp);
//Tentukan biner lokal dalam lima tupel, yaitu alamat host lokal dan nomor port
sock.Bind
(serverFullAddr);
/Listen Apakah ada koneksi masuk, tentukan nilai maksimum antrian koneksi yang tertunda menjadi 20
sock.Listen(20);
alSock = Daftar Array baru();
//Buat pengatur waktu dengan jeda waktu 1 detik, yaitu, jalankan metode terima() setiap detik untuk mendapatkan permintaan koneksi pertama yang tertunda dalam antrian permintaan koneksi
myTimer =new System.Timers.Timer(1000 )
; Berlalu +=Sistem.Timers.ElapsedEventHandler(myTimer_Elapsed);
myTimer.Enabled = true
;
private void myTimer_Elapsed(pengirim objek, System.Timers.ElapsedEventArgs e)
{
myTimer.Enabled = false;
//Jalankan terima(), thread ini akan diblokir ketika antrian penangguhan kosong, dan pengatur waktu akan berhenti karena pernyataan sebelumnya , sampai // sampai koneksi diteruskan ke
Socket menerimaSock = sock.Accept();
//
Simpan objek Socket yang dihasilkan oleh menerima() ke dalam ArrayList
alSock.Add(acceptSock);
yang akan menyebabkan program memulai thread lain. Utas akan menjalankan fungsi panggilan balik, dan batas delegasi //parameter fungsi harus bertipe objek. Parameter kedua dari konstruktor Threading.Timer adalah parameter yang diteruskan ke fungsi panggilan balik; //Parameter ketiga menentukan penundaan sebelum memanggil fungsi panggilan balik, jika 0, maka akan segera dimulai; fungsi panggilan balik // Interval, jika disetel ke 0, hanya akan dijalankan satu kali.
Sistem.Threading.Timer ti = Sistem.Threading.Timer baru(
TimerCallback baru(ReceiveMsg), terimaSock, 0, 0);
myTimer.Enabled = true
;
private void Terima Pesan(objek objek)
{
Soket terimaSock = (Soket)obj;
coba
{
while (benar)
{
byte[]byteArray
=byte
baru[100];
array menjadi
string strRec = System.Text.Encoding.UTF8.GetString(byteArray);
if (this.rtbReceive.InvokeRequired)
{
this.rtbReceive.Invoke(new EventHandler(this.ChangeRickTextBox),objek
baru
[] { strRec ,EventArgs.Empty });
}
}
}
catch(Pengecualian ex)
{
acceptSock.Close();
MessageBox.Show("S:Terima Pesan Error"+ex.Message
)
;
private void ChangeRickTextBox(objek objek,EventArgs e)
{
string s = System.Convert.ToString(obj);
this.rtbReceive.AppendText(s + Environment.NewLine
}
private
void
btSend_Click(pengirim objek, EventArgs e)
{
Socket
sc=null;
byte[] byteSend =
System.Text.Encoding.UTF8.GetBytes(this.tbSend.Text.ToCharArray
());
pada saat yang sama Ketika klien terhubung, masukkan koneksi mana yang akan dikirim textBox1
int index = int.Parse(this.textBox1.Text.Trim(
));
sc
= (Socket)alSock[index - 1];
.Kirim(byteSend);
}
catch(Pengecualian ex)
{
if(sc != null)
{
sc.Close();
}
MessageBox.Show
("S:Kirim Pesan Kesalahan"+ex.Pesan)
;
private void btClose_Click(pengirim objek, EventArgs e)
{
coba
{
Application.Exit();
}
catch(
Pengecualian ex)
{
MessageBox.Show
("
S:Close Socket Error" + ex.Message
)
;
= == == == == == == == == == == == == == == == == == == == == == == == = = = = == == == ==
Klien:
menggunakan System.Net;
menggunakan System.Net.Sockets
menggunakan System.Threading;
namespace MySocketClient1
{
kelas parsial publik Form1 : Formulir
{
private IPAddress serverIP = IPAddress.Parse("127.0.0.1");
private IPEndPoint serverFullAddr
;
Formulir publik1()
{
InisialisasiKomponen()
;
private void btConnect_Click(pengirim objek, EventArgs e)
{
coba
{
serverFullAddr = new IPEndPoint(serverIP, 1000);
sock
= new Socket(AddressFamily.InterNetwork, SocketType.Stream,
ProtocolType.Tcp);
Buat koneksi ke host jarak jauh
//Mulai thread baru untuk menerima data
Thread t = new Thread(new ThreadStart(ReceiveMsg));
t.Name = "Receive Message";
//Thread bisa berupa thread latar belakang atau thread latar depan. Thread latar belakang mirip dengan thread latar depan, hanya saja thread latar belakang // tidak mencegah proses dihentikan. Setelah semua thread latar depan milik suatu proses dihentikan, runtime bahasa umum // mengakhiri proses dengan memanggil Abort pada thread latar belakang mana pun yang masih aktif.
t.IsBackground = benar;
t.Start();
}
catch(Pengecualian ex)
{
MessageBox.Show
(ex.Message)
;
private
void
AcceptMsg()
{
coba
{
while (true)
{
byte[] byteRec = byte baru[100];
this.sock.Receive(byteRec);
string strRec = System.Text.Encoding.UTF8.GetString(byteRec);
(this.rtbReceive.InvokeRequired)
{
this.rtbReceive.Invoke(
new
EventHandler
(ChangeRtb)
, objek baru[]
{
strRec, EventArgs.Empty })
;
"+mis.Pesan);
}
}
private void ChangeRtb(objek objek, EventArgs e)
{
string s = System.Convert.ToString(obj);
this.rtbReceive.AppendText(s + Environment.NewLine
}
private void btSend_Click(pengirim objek, EventArgs e)
{
byte[] byteSend =
System.Text.Encoding.UTF8.GetBytes(this.tbSend.Text.ToCharArray());
coba
{
this.sock.Send(byteSend
}
tangkap
{
MessageBox.Show("Kesalahan Pengiriman Pesan"
)
;
private void btClose_Click(pengirim objek, EventArgs e)
{
coba
{
this.sock.Shutdown(
SocketShutdown.Receive)
;
this.sock.Close
(
)
;
;
} } }
}
}
Puzzle
:
Pernyataan bertanda merah di sisi klien: this.sock.Shutdown(SocketShutdown.Receive), jika diubah menjadi
this.sock.Shutdown(SocketShutdown.Both); Send);
lalu ketika tombol Close diklik, penggunaan CPU meroket hingga 100%. Namun, menggunakan metode this.sock.Shutdown(SocketShutdown.Receive);
atau tidak memanggil metode Shutdown() tidak menimbulkan masalah ini. Bukankah klien seharusnya menggunakan Shutdown()?
http://www.cnblogs.com/KissKnife/archive/2006/08/13/475707.html