How using the class library for making chatting,send file,capture screen,file managemen, etc application via socket tcp ip

Ok, let us start.....(i assume, you know how to import class library from visual studio, if not there is documentation that i have included, so you can learn from there. You can download the documentation and complete project CLIENT and SERVER here:

• myg3nx.socket.classlibrary v.1.2.4.0 (Indonesia).zip 
• myg3nx.socket.classlibrary v.1.2.4.0 (English).zip. )

We will make advanced program using this class library. Now, our application have 2 project. They are Server and client.

Server have function like this:

1. listening incoming connection
2. send message to client (chatting application)
3. send broadcast messages to clients
4. kill process at client
5. retrive list drive,file and folder on the specific client
6. upload and download file larger than 2 gigabyte (send and receive file to/from client), can send single file or multiple file (if you send folder and in the folder have subfolder and alot file in it, you dont need to create prototype like creating list file recursively... the library will handle it for you)
7. screen capture from desktop screen client
8. much more

 Client have function like this:

1. request connection
2. send message to server
3. send message to other client
4. much more

 SERVER
<br /> using System;<br /> using System.Collections.Generic;<br /> using System.ComponentModel;<br /> using System.Data;<br /> using System.Drawing;<br /> using System.Linq;<br /> using System.Text;<br /> using System.Windows.Forms;<br /> //// namespace import library that allows you to access a public class that is<br /> using MYG3NX.Server;<br /> namespace Server<br /> {<br /> public partial class Form1 : Form<br /> {<br /> string temp1 = "",temp2="",temp3="";<br /> delegate void setTextCallback(string text);<br /> delegate void setTransferProgress(long offset,long length);<br /> /// <summary><br /> /// membuat object baru dari class MyServer()<br /> /// </summary><br /> MyServer ms1 = new MyServer();<br /> public Form1()<br /> {<br /> InitializeComponent();<br /> // initialize all the custom event handler of the object myserver that has been made<br /> ms1.signalCommand += new MyServer.getSignalData(ms1_getSignalCommand);<br /> ms1.signalMessage += new MyServer.getSignalData(ms1_getSignalMessage);<br /> ms1.signalFileTransferProgress += new MyServer.getSignalData(ms1_signalFileTransferProgress);<br /> ms1.signalHistory += new MyServer.getSignalData(ms1_signalHistory);<br /> ms1.signalIsServerActive += new MyServer.getSignalData(ms1_signalIsServerActive);<br /> }<br /> #region fungsi custom event handler<br /> // This function is useful for performing a process where, ms1.signalCommand<br /> // Ms1.signalMessage, ms1.signalFileTransferProgress, ms1.signalHistory, ms1.signalIsServerActive<br /> // Has occurred an event<br /> private void ms1_getSignalCommand() {<br /> if (!commandThread.IsBusy)<br /> {<br /> commandThread.RunWorkerAsync();<br /> }<br /> }<br /> private void ms1_getSignalMessage() {<br /> setTextMsgReceiv(ms1.getSenderId+" : "+ms1.getMessageClient);<br /> }<br /> private void ms1_signalFileTransferProgress() {<br /> setFileTransferProgress(ms1.getFileTransferOffset, ms1.getFileTransferLength);<br /> setTextFileTransfer(ms1.getFileTransferProgress);<br /> }<br /> private void ms1_signalHistory() {<br /> setTextHistoryReceiv(System.DateTime.Now.ToString("d/M/yyyy h:mm:ss tt") + " : "+ms1.getHistory);<br /> }<br /> private void ms1_signalIsServerActive() {<br /> if (ms1.isServerActive) <br /> { setTextHistoryReceiv(System.DateTime.Now.ToString("d/M/yyyy h:mm:ss tt") + " : Server Active"); }<br /> if (!ms1.isServerActive) <br /> { setTextHistoryReceiv(System.DateTime.Now.ToString("d/M/yyyy h:mm:ss tt") + " : Server Stop"); }<br /> }<br /> #endregion<br /> <br /> #region thread aman/safty thread<br /> // Because the properties of the data object myserver done by another thread, then<br /> // If we're going to give Windows Components data / value of these properties<br /> // Required to check the properties of each component InvokeRequired form<br /> // If not, then the cross-thread exception will occur<br /> void setTextMsgReceiv(string text)<br /> {<br /> if (msgReceiv.InvokeRequired)<br /> {<br /> setTextCallback stc = new<br /> setTextCallback(setTextMsgReceiv);<br /> Invoke(stc, new object[] { text });<br /> }<br /> else<br /> {<br /> msgReceiv.Items.Add(text);<br /> }<br /> }<br /> void setTextHistoryReceiv(string text)<br /> {<br /> if (historyReceiv.InvokeRequired)<br /> {<br /> setTextCallback stc = new<br /> setTextCallback(setTextHistoryReceiv);<br /> Invoke(stc, new object[] { text });<br /> }<br /> else<br /> {<br /> historyReceiv.Items.Add(text);<br /> }<br /> }<br /> void setTextFileTransfer(string text)<br /> {<br /> if (fileTransfer.InvokeRequired)<br /> {<br /> setTextCallback stc = new<br /> setTextCallback(setTextFileTransfer);<br /> Invoke(stc, new object[] { text });<br /> }<br /> else<br /> {<br /> fileTransfer.Text=text;<br /> }<br /> }<br /> void setFileTransferProgress(long offset,long length)<br /> {<br /> if (fileTransferProgress.InvokeRequired)<br /> {<br /> setTransferProgress stp = new<br /> setTransferProgress(setFileTransferProgress);<br /> Invoke(stp, new object[] { offset,length });<br /> }<br /> else<br /> {<br /> fileTransferProgress.Minimum = 0;<br /> fileTransferProgress.Maximum = (int)length;<br /> if (offset < length) { fileTransferProgress.Value = (int)offset; return; } } } private void commandThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) { string command = ms1.getCommand; string senderId = ms1.getSenderId; if (command.StartsWith("[none]")) { command = command.Remove(0, 6); // To retrieve data and textMsg captionMsg, then we have to do a "split" // That has been initialized by the client by using the string "[]" as // Delimiter / seperator string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1]); } else if (command.StartsWith("[error]")) { command = command.Remove(0, 7); string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1], MessageBoxButtons.OK, MessageBoxIcon.Error); } else if (command.StartsWith("[question]")) { command = command.Remove(0, 10); string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1], MessageBoxButtons.OK, MessageBoxIcon.Question); } else if (command.StartsWith("[information]")) { command = command.Remove(0, 13); string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1], MessageBoxButtons.OK, MessageBoxIcon.Information); } } #endregion private void updateButton() { start.Enabled = !start.Enabled; stop.Enabled = !stop.Enabled; } private void Form1_Load(object sender, EventArgs e) { start.Enabled = false; updateButton(); } private void start_Click(object sender, EventArgs e) { // Give a buffer to the socket server that is useful as a receiving / sending data to the client. // If you use the class library is on a LAN (local area network), // We recommend using a large buffer (this will have a big impact // The file transfer speed), but if the internet // Network please koment line in the code below, it will automatically use // Default settings, ie 512 B (bytes) ms1.BufferSocket = (16 * 1024); ////////////////////////////////// ms1.Port = int.Parse(port.Text); ms1.ServerId = idServer.Text; ms1.TotalClient = 10; if (!ms1.isServerActive) { ms1.startServer(); updateButton(); } } private void stop_Click(object sender, EventArgs e) { if (ms1.isServerActive) { ms1.stopServer(); updateButton(); } } private void client_Click(object sender, EventArgs e) { client.Items.Clear(); string[] clients = ms1.getConnectedClients(); if (clients != null) { client.Items.AddRange(clients); } } private void sendMsg_Click(object sender, EventArgs e) { int result = ms1.sendMessageToClient(msg.Text,client.Text); if (result != 0) { msgReceiv.Items.Add(ms1.ServerId + " : " + msg.Text); historyReceiv.Items.Add("Message send sucsessfull to "+client.Text); return; } historyReceiv.Items.Add("Message send unsucsessfull"); } private void sendBroadcastMsg_Click(object sender, EventArgs e) { ms1.sendBroadcastMessage(msg.Text); } private void sendCommand_Click(object sender, EventArgs e) { string command = ""; switch (typeMsgBox.SelectedIndex) { case 0: command = "[none]"; break; case 1: command = "[error]"; break; case 2: command = "[question]"; break; case 3: command = "[information]"; break; } if (command != "") { // Sign "[]" serves as a seperator / delimiter that will be useful for // Further processing by the client string temp = command + captionMsg.Text + "[]" + textMsg.Text; ms1.sendCommandToClient(temp,client.Text); } } private void prosesRefresh_Click(object sender, EventArgs e) { prosesList.Items.Clear(); string[]result=ms1.getRunningProcessesAtClient(client.Text); if (result != null) { prosesList.Items.AddRange(result); } } private void prosesKill_Click(object sender, EventArgs e) { int result = ms1.setKillProcessAtClient(prosesList.SelectedItem.ToString(), client.Text); if (result == 1) { historyReceiv.Items.Add("Successfull kill of proses "+prosesList.SelectedItem.ToString()); } if (result == 0) { historyReceiv.Items.Add("Unsuccessfull kill of proses " + prosesList.SelectedItem.ToString()); } } private void prosesExecute_Click(object sender, EventArgs e) { int result = ms1.setRunProcessAtClient(pathAddressProses.Text, client.Text); if (result == 1) { historyReceiv.Items.Add("Successfull execute of proses " + pathAddressProses.Text); } if (result == 0) { historyReceiv.Items.Add("Unsuccessfull execute of proses " + pathAddressProses.Text); } } private void screenShoot_Click(object sender, EventArgs e) { Image img = ms1.getScreenShotAtClient(client.Text); if (img != null) { pictureBoxScreenShoot.Image = img; } } private void saveImageToolStripMenuItem_Click(object sender, EventArgs e) { SaveFileDialog sfd = new SaveFileDialog(); sfd.Filter = "Image File|*.jpeg"; sfd.FileName = "screenshoot.jpeg"; if (sfd.ShowDialog() != DialogResult.OK) { return; } pictureBoxScreenShoot.Image.Save(sfd.FileName); } private void driveList_Click(object sender, EventArgs e) { driveList.Items.Clear(); string[] result = ms1.getDrivesListAtClient(client.Text); if (result != null) { driveList.Items.AddRange(result); } } private void fileAndFolder_Click(object sender, EventArgs e) { fileList.Items.Clear(); folderList.Items.Clear(); string[] result1 = ms1.getFilesListAtClient(driveList.Text+ textBox7.Text,client.Text); string[] result2 = ms1.getFoldersListAtClient(driveList.Text + textBox7.Text, client.Text); if (result1 != null) { fileList.Items.AddRange(result1); } if (result2 != null) { folderList.Items.AddRange(result2); } textBox8.Text = (textBox7.Text.EndsWith("\\")?textBox7.Text:textBox7.Text+"\\"); } private void folderList_Click(object sender, EventArgs e) { if (folderList.SelectedIndex == -1) { return; } textBox7.Text = textBox8.Text + folderList.SelectedItem.ToString() + "\\"; } private void fileList_Click(object sender, EventArgs e) { if (fileList.SelectedIndex == -1) { return; } sizeFile.Text =ms1.getFileSizeAtClient(driveList.Text + textBox8.Text+fileList.SelectedItem.ToString(), client.Text).ToString()+" byte(s)"; } private void delete_Click(object sender, EventArgs e) { if (fileList.SelectedIndex == -1) { return; } int result = ms1.setDeleteFileAtClient(driveList.Text + textBox8.Text + fileList.SelectedItem.ToString(), client.Text); if (result == 1) { historyReceiv.Items.Add("Successfull delete of file " + fileList.SelectedItem.ToString()); } if (result == 0) { historyReceiv.Items.Add("Unsuccessfull delete of file " + fileList.SelectedItem.ToString()); } } private void getBytes_Click(object sender, EventArgs e) { if (fileList.SelectedIndex == -1) { return; } byte[] result = ms1.getFileAsByteAtClient(driveList.Text + textBox8.Text + fileList.SelectedItem.ToString(), client.Text); if (result != null) { ////////////// lakukan proses dengan byte[] result yang telah diterima } } private void download_Click(object sender, EventArgs e) { if (fileList.SelectedIndex == -1) { return; } FolderBrowserDialog fbd = new FolderBrowserDialog(); fbd.Description = "Download file"; if (fbd.ShowDialog() != DialogResult.OK) { return; } ms1.SaveFilePathAddress = fbd.SelectedPath+"\\"; temp1 = driveList.Text + textBox8.Text + fileList.SelectedItem.ToString(); temp2 = client.Text; // Due to donwload the file can take a long time, we can make // Another thread to perform the process, it is intended that our application // Still responsive to receiving input from the user new System.Threading.Thread(downloadFile).Start(); } private void upload_Click(object sender, EventArgs e) { OpenFileDialog sfd = new OpenFileDialog(); sfd.Filter = "All File|*.*"; sfd.Title = "Send File"; if (sfd.ShowDialog() != DialogResult.OK) { return; } temp1 = sfd.FileName; temp2 = client.Text; // Due to upload the file can take a long time, we can make // Another thread to perform the process, it is intended that our application // Still responsive to receiving input from the user new System.Threading.Thread(uploadFile).Start(); } private void downloadFile() { int result = ms1.getFile(temp1, temp2); switch (result) { case 0: setTextHistoryReceiv("Download file uncomplate"); break; case 1: setTextHistoryReceiv("Download file complate"); break; case 2: MessageBox.Show("Only one progress of transfer file are alowed"); break; } } private void uploadFile() { int result = ms1.sendFile(temp1, temp2); switch (result) { case 0: setTextHistoryReceiv("Upload file uncomplate"); break; case 1: setTextHistoryReceiv("Upload file complate"); break; case 2: MessageBox.Show("Only one progress of transfer file are alowed"); break; } } private void abortTransfer_Click(object sender, EventArgs e) { int result = ms1.fileTransferAbort(); if (result == 0) { MessageBox.Show("Nothing to cancel file transfer operation"); } } private void Form1_FormClosing(object sender, FormClosingEventArgs e) { ms1.fileTransferAbort(); System.Threading.Thread.Sleep(1000); Application.ExitThread(); } } }


CLIENT


<br /> using System;<br /> using System.Collections.Generic;<br /> using System.ComponentModel;<br /> using System.Data;<br /> using System.Drawing;<br /> using System.Linq;<br /> using System.Text;<br /> using System.Windows.Forms;<br /> // import namespace library that allows you to access a public class that is<br /> using MYG3NX.Client;<br /> namespace Client<br /> {<br /> public partial class Form1 : Form<br /> {<br /> string temp1 = "",temp2="",temp3="";<br /> delegate void setButton(bool enable);<br /> delegate void setTextCallback(string text);<br /> delegate void setTransferProgress(long offset,long length);<br /> /// <summary><br /> /// membuat object baru dari class MyClient()<br /> /// </summary><br /> MyClient mc1 = new MyClient();<br /> client configFile = new client();<br /> public Form1()<br /> {<br /> InitializeComponent();<br /> // initialize all the custom event handler of the object myClient that<br /> // has been made<br /> mc1.signalCommand += new MyClient.getSignalData(mc1_getSignalCommand);<br /> mc1.signalMessage += new MyClient.getSignalData(mc1_getSignalMessage);<br /> mc1.signalFileTransferProgress += new MyClient.getSignalData(mc1_signalFileTransferProgress);<br /> mc1.signalHistory += new MyClient.getSignalData(mc1_signalHistory);<br /> mc1.signalIsClientActive += new MyClient.getSignalData(mc1_signalIsClientActive);<br /> }<br /> #region fungsi custom event handler<br /> // This function is useful for performing a process where <br /> // ms1.signalCommand, ms1.signalMessage, ms1.signalFileTransferProgress, <br /> // ms1.signalHistory, ms1.signalIsClientActive<br /> // there has been an event<br /> private void mc1_getSignalCommand() {<br /> if (!commandThread.IsBusy)<br /> {<br /> commandThread.RunWorkerAsync();<br /> }<br /> }<br /> private void mc1_getSignalMessage() {<br /> setTextMsgReceiv(mc1.getSenderId+" : "+mc1.getMessageServer);<br /> }<br /> private void mc1_signalFileTransferProgress() {<br /> setFileTransferProgress(mc1.getFileTransferOffset, mc1.getFileTransferLength);<br /> setTextFileTransfer(mc1.getFileTransferProgress);<br /> }<br /> private void mc1_signalHistory() {<br /> setTextHistoryReceiv(System.DateTime.Now.ToString("d/M/yyyy h:mm:ss tt") + " : "+mc1.getHistory);<br /> }<br /> private void mc1_signalIsClientActive()<br /> {<br /> if (mc1.isClientActive) { setTextHistoryReceiv(System.DateTime.Now.ToString("d/M/yyyy h:mm:ss tt") + " : Client Active");<br /> }<br /> if (!mc1.isClientActive) { setTextHistoryReceiv(System.DateTime.Now.ToString("d/M/yyyy h:mm:ss tt") + " : Client Stop");<br /> buttonUpdateStart(true);<br /> buttonUpdateStop(false);<br /> }<br /> }<br /> #endregion<br /> <br /> #region thread aman/safty thread<br /> // because the properties of the data object MyClient done by another <br /> // thread, so if we will provide the data windows Components / value of <br /> // these properties are required to check the properties of each component <br /> // InvokeRequired form if not, then the cross-thread exception will occur<br /><br /> void buttonUpdateStart(bool enable)<br /> {<br /> if (start.InvokeRequired)<br /> {<br /> setButton sb = new<br /> setButton(buttonUpdateStart);<br /> Invoke(sb, new object[] { enable });<br /> }<br /> else<br /> {<br /> start.Enabled = enable;<br /> }<br /> }<br /> void buttonUpdateStop(bool enable)<br /> {<br /> if (stop.InvokeRequired)<br /> {<br /> setButton sb = new<br /> setButton(buttonUpdateStop);<br /> Invoke(sb, new object[] { enable });<br /> }<br /> else<br /> {<br /> stop.Enabled = enable;<br /> }<br /> }<br /> void setTextMsgReceiv(string text)<br /> {<br /> if (msgReceiv.InvokeRequired)<br /> {<br /> setTextCallback stc = new<br /> setTextCallback(setTextMsgReceiv);<br /> Invoke(stc, new object[] { text });<br /> }<br /> else<br /> {<br /> msgReceiv.Items.Add(text);<br /> }<br /> }<br /> void setTextHistoryReceiv(string text)<br /> {<br /> if (historyReceiv.InvokeRequired)<br /> {<br /> setTextCallback stc = new<br /> setTextCallback(setTextHistoryReceiv);<br /> Invoke(stc, new object[] { text });<br /> }<br /> else<br /> {<br /> historyReceiv.Items.Add(text);<br /> }<br /> }<br /> void setTextFileTransfer(string text)<br /> {<br /> if (fileTransfer.InvokeRequired)<br /> {<br /> setTextCallback stc = new<br /> setTextCallback(setTextFileTransfer);<br /> Invoke(stc, new object[] { text });<br /> }<br /> else<br /> {<br /> fileTransfer.Text=text;<br /> }<br /> }<br /> void setFileTransferProgress(long offset,long length)<br /> {<br /> if (fileTransferProgress.InvokeRequired)<br /> {<br /> setTransferProgress stp = new<br /> setTransferProgress(setFileTransferProgress);<br /> Invoke(stp, new object[] { offset,length });<br /> }<br /> else<br /> {<br /> fileTransferProgress.Minimum = 0;<br /> fileTransferProgress.Maximum = (int)length;<br /> if (offset < length) { fileTransferProgress.Value = (int)offset; return; } } } private void commandThread_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) { string command = mc1.getCommand; string senderId = mc1.getSenderId; if (command.StartsWith("[none]")) { command = command.Remove(0, 6); // to retrieve data and textMsg captionMsg, then we have to do a "split" that // has been initialized by the client by using the string "[]" as a delimiter / // seperator string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1]); } else if (command.StartsWith("[error]")) { command = command.Remove(0, 7); string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1], MessageBoxButtons.OK, MessageBoxIcon.Error); } else if (command.StartsWith("[question]")) { command = command.Remove(0, 10); string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1], MessageBoxButtons.OK, MessageBoxIcon.Question); } else if (command.StartsWith("[information]")) { command = command.Remove(0, 13); string[] data = command.Split(new string[] { "[]" }, StringSplitOptions.None); MessageBox.Show(data[0], data[1], MessageBoxButtons.OK, MessageBoxIcon.Information); } } #endregion private void updateButton() { start.Enabled = !start.Enabled; stop.Enabled = !stop.Enabled; } private void Form1_Load(object sender, EventArgs e) { ipServer.Text = configFile.ipServer; port.Text = configFile.port.ToString(); idClient.Text = configFile.clientID; start.Enabled = false; updateButton(); } private void start_Click(object sender, EventArgs e) { // give a buffer to the socket client that is useful as a receiving / sending // data to the client. if you use the class library is on a LAN (local area // network), we recommend using a large buffer (this will have a big impact on // the speed of file transfer), but if the internet network please commentline // in the code below, then automatically using default settings, ie 512 B (bytes) // allocate byte buffer as much as 16 KB (kilo bytes) mc1.BufferSocket = (16 * 1024); ////////////////////////////////// mc1.Port = int.Parse(port.Text); mc1.ClientId = idClient.Text; mc1.IpServer = ipServer.Text; if (!mc1.isClientActive) { updateButton(); mc1.connectToServer(); } } private void stop_Click(object sender, EventArgs e) { if (mc1.isClientActive) { updateButton(); mc1.disconnectFromServer(); } } private void client_Click(object sender, EventArgs e) { client.Items.Clear(); string[] clients = mc1.getConnectedClients(); if (clients != null) { client.Items.AddRange(clients); } } private void sendMsgServer_Click(object sender, EventArgs e) { int result = mc1.sendMessageToServer(msg.Text); if (result != 0) { msgReceiv.Items.Add(mc1.ClientId + " : " + msg.Text); historyReceiv.Items.Add("Message send sucsessfull to server"); return; } historyReceiv.Items.Add("Message send unsucsessfull"); } private void sendMsgClient_Click(object sender, EventArgs e) { int result = mc1.sendMessageToClient(msg.Text, client.Text); if (result != 0) { msgReceiv.Items.Add(mc1.ClientId + " : " + msg.Text); historyReceiv.Items.Add("Message send sucsessfull to " + client.Text); return; } historyReceiv.Items.Add("Message send unsucsessfull"); } private void sendCommand_Click(object sender, EventArgs e) { string command = ""; switch (typeMsgBox.SelectedIndex) { case 0: command = "[none]"; break; case 1: command = "[error]"; break; case 2: command = "[question]"; break; case 3: command = "[information]"; break; } if (command != "") { // to retrieve data and textMsg captionMsg, then we have to do a "split" that // has been initialized by the client by using the string "[]" as a delimiter / // seperator string temp = command + captionMsg.Text + "[]" + textMsg.Text; mc1.sendCommandToServer(temp); } } } }

You can download the complate project and documentation here:

• myg3nx.socket.classlibrary v.1.2.4.0 (Indonesia).zip
• myg3nx.socket.classlibrary v.1.2.4.0 (English).zip

If any question just post it here :) see ya