.NET 2.x Многопользовательский чат на TcpClient - C#

Узнай цену своей работы

Формулировка задачи:

Решил написать чат. сервер:
Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5.  
  6. using System.Threading;
  7. using System.Net.Sockets;
  8. using System.Net;
  9. using System.Runtime.InteropServices;
  10.  
  11. namespace ConsoleApplication1
  12. {
  13.     class Program
  14.     {
  15.  
  16.         const int port=3128;
  17.         public static List<user> users = new List<user>();
  18.         public static user tmpuser = new user();
  19.  
  20.         public static TcpListener listener;
  21.         public static Thread conn;
  22.  
  23.         static bool doneserver;
  24.  
  25.         public static string host = Dns.GetHostName();
  26.         public static string myIp = Dns.GetHostByName(host).AddressList[0].ToString();
  27.         
  28.         static void Main(string[] args)
  29.         {
  30.             IPAddress localhost = IPAddress.Parse(myIp);
  31.             listener = new TcpListener(localhost, port);
  32.             listener.Start();
  33.  
  34.             Console.WriteLine("Сервер запущен...\r\n");
  35.             
  36.             conn = new Thread(connection);
  37.             conn.Start();
  38.         }
  39.  
  40.         static string ReadMessage(TcpClient client)
  41.         {
  42.             byte[] buffer = new byte[256];
  43.             int totalRead = 0;
  44.             do
  45.             {
  46.                 int read = client.GetStream().Read(buffer, totalRead, buffer.Length - totalRead);
  47.                 totalRead += read;
  48.             } while (client.GetStream().DataAvailable);
  49.             return Encoding.Unicode.GetString(buffer, 0, totalRead);
  50.         }
  51.  
  52.         public static void connection()
  53.         {
  54.             doneserver = false;
  55.             Thread thread;
  56.             while (!doneserver)
  57.             {
  58.                 TcpClient client = listener.AcceptTcpClient();
  59.                 Console.WriteLine("Клиент подключен. IP:{0}",client.Client.RemoteEndPoint.ToString());
  60.                 thread = new Thread(new ParameterizedThreadStart(HandledientThread));
  61.                 thread.Start(client);
  62.                 
  63.             }
  64.         }
  65.  
  66.         static void HandledientThread(object obj)
  67.         {
  68.             TcpClient clientid = obj as TcpClient;
  69.             bool done = false;
  70.  
  71.             while (!done)
  72.             {
  73.                 string message = ReadMessage(clientid);
  74.  
  75.                 string flag = "";
  76.                 string mess = "";
  77.  
  78.                 flag += message[0];
  79.                 //////////////если прислал сообщение////////
  80.                 if (flag == "m")
  81.                 {
  82.                     Console.WriteLine("log::m::{0}",message);
  83.  
  84.                     for (int i = 1; i < message.Length; i++)
  85.                     {
  86.                         mess += message[i];
  87.                     }
  88.  
  89.                     Console.WriteLine(mess);
  90.                     SendMessageAll(clientid, mess, "m");
  91.                 }
  92.                 //////////////если прислал ник///////////////
  93.                 if (flag == "n")
  94.                 {
  95.                     for (int i = 1; i < message.Length; i++)
  96.                     {
  97.                         mess += message[i];
  98.                     }
  99.  
  100.                     tmpuser.add(mess, clientid);
  101.                     users.Add(tmpuser);
  102.  
  103.                     SendMessageAll(clientid, mess, "a");
  104.                     mess = "";
  105.  
  106.                     Console.WriteLine("//////////////////////////////////////");
  107.  
  108.                     foreach (user tmp in users)
  109.                     {
  110.                         Console.Write("name:{0}",tmp.name);
  111.                         Console.WriteLine("klient:{0}", tmp.klient.Client.RemoteEndPoint.ToString());
  112.                        
  113.                         if(clientid!=tmp.klient)
  114.                             mess += tmp.name + ";";
  115.                     }
  116.  
  117.                     Console.WriteLine("///////////////////////////////////////");
  118.                     Console.Write("log:::n:::{0}", mess);
  119.  
  120.                     SendMessage(clientid, mess, "l");
  121.                 }
  122.                 ///////////////если отключился/////////////
  123.                 if (flag == "o")
  124.                 {
  125.                     Console.WriteLine("log::o::{0}", message);
  126.  
  127.                     for (int i = 1; i < message.Length; i++)
  128.                     {
  129.                         mess += message[i];
  130.                     }
  131.                     SendMessageAll(clientid,mess, "z");
  132.                     user tmp2 = new user();
  133.                     foreach (user tmp in users)
  134.                     {
  135.                         if (tmp.klient == clientid)
  136.                         {
  137.                             tmp2.add(tmp.name, tmp.klient);
  138.                         }
  139.                     }
  140.                     users.Remove(tmp2);
  141.                     done = true;
  142.                 }
  143.  
  144.             }
  145.             Console.WriteLine("Клиент отключен. IP:{0}",clientid.Client.RemoteEndPoint);
  146.             
  147.             clientid.Close();
  148.         }
  149.  
  150.         static void SendMessage(TcpClient client, string message, string flag)
  151.         {
  152.             flag += message;
  153.             byte[] bytes = Encoding.Unicode.GetBytes(flag);
  154.             client.GetStream().Write(bytes, 0, bytes.Length);
  155.         }
  156.  
  157.         static void SendMessageAll(TcpClient client, string message, string flag)
  158.         {
  159.             flag += message;
  160.             byte[] bytes = Encoding.Unicode.GetBytes(flag);
  161.             foreach (user tmp in users)
  162.             {
  163.                 if (tmp.klient!=client)
  164.                     tmp.klient.GetStream().Write(bytes, 0, bytes.Length);
  165.             }
  166.         }
  167.     }
  168.  
  169.     public class user
  170.     {
  171.         public int id;
  172.         public string name;
  173.         public TcpClient klient;
  174.  
  175.         public void add(int aid, string aname, TcpClient aklient)
  176.         {
  177.             id = aid;
  178.             name = aname;
  179.             klient = aklient;
  180.         }
  181.     }
  182. }
Клиент:
Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.ComponentModel;
  4. using System.Data;
  5. using System.Drawing;
  6. using System.Text;
  7. using System.Windows.Forms;
  8.  
  9. using System.Net.NetworkInformation;
  10. using System.Net.Sockets;
  11. using System.Net;
  12. using System.Threading;
  13. using System.Runtime.Serialization.Formatters.Binary;
  14.  
  15. namespace Внутреняя_ICQ_Клиент_
  16. {
  17.     public partial class Form1 : Form
  18.     {
  19.  
  20.         IPAddress ipserver;
  21.         int port;
  22.         TcpClient clientkl;
  23.         Thread read;
  24.         public string NIK;
  25.  
  26.         public Form1()
  27.         {
  28.             InitializeComponent();
  29.         }
  30.  
  31.         private void пользователиВСетиToolStripMenuItem_Click(object sender, EventArgs e)
  32.         {
  33.             if (textBox1.Text != "")
  34.             {
  35.                 NIK = textBox1.Text;
  36.                 ipserver=IPAddress.Parse(textBox2.Text.ToString());
  37.                 port=Convert.ToInt32(textBox5.Text);
  38.                 if (пользователиВСетиToolStripMenuItem.Text == "Подключиться")
  39.                 {
  40.  
  41.                     пользователиВСетиToolStripMenuItem.Text = "Отключиться";
  42.                     ///////вкладки///////////////
  43.                     panelmessage.Visible = true;
  44.                     panellogin.Visible = false;
  45.                     panelconfig.Visible=false;
  46.                     /////////////////////////////
  47.                     try
  48.                     {
  49.                         clientkl = new TcpClient();
  50.                         clientkl.Connect(ipserver, port);
  51.  
  52.                         SendMessage(clientkl, NIK, "n");
  53.                     
  54.                         read = new Thread(new ParameterizedThreadStart(Read));
  55.                         read.Start(clientkl);
  56.                     }
  57.                     catch
  58.                     {
  59.                         MessageBox.Show("[X] Сервер не доступен!");
  60.                         пользователиВСетиToolStripMenuItem.Text = "Подключиться";
  61.                         ///////вкладки///////////////
  62.                         panelmessage.Visible = false;
  63.                         panellogin.Visible = true;
  64.                         panelconfig.Visible = false;
  65.                         /////////////////////////////
  66.  
  67.                         //read.Abort();
  68.                         clientkl.Close();
  69.  
  70.                     }
  71.                 }
  72.                 else
  73.                 {
  74.                     ///////вкладки///////////////
  75.                     panelmessage.Visible = false;
  76.                     panellogin.Visible = true;
  77.                     panelconfig.Visible=false;
  78.                     /////////////////////////////
  79.  
  80.                     пользователиВСетиToolStripMenuItem.Text = "Подключиться";
  81.                     SendMessage(clientkl, NIK, "o");
  82.                     
  83.                 }
  84.             }
  85.             else
  86.             {
  87.                 ///////вкладки///////////////
  88.                 panelmessage.Visible = false;
  89.                 panellogin.Visible = true;
  90.                 panelconfig.Visible = false;
  91.                 /////////////////////////////
  92.                 MessageBox.Show("Введите НИК");
  93.                 textBox1.Focus();
  94.             }
  95.         }
  96.  
  97.         private void настройкиToolStripMenuItem_Click(object sender, EventArgs e)
  98.         {
  99.             ///////вкладки///////////////
  100.             panelmessage.Visible = false;
  101.             panellogin.Visible = false;
  102.             panelconfig.Visible = true;
  103.             /////////////////////////////
  104.         }
  105.  
  106.         private static void SendMessage(TcpClient client, string message, string flag) 
  107.         {
  108.             flag += message;
  109.             byte[] bytes = Encoding.Unicode.GetBytes(flag);
  110.             client.GetStream().Write(bytes, 0, bytes.Length);
  111.         }
  112.  
  113.         public void Read(object obj)
  114.         {
  115.             TcpClient client = obj as TcpClient;
  116.             bool done = false;
  117.             while (!done)
  118.             {
  119.                 try
  120.                 {
  121.                     string message = ReadResponse(client);
  122.  
  123.                     string flag = "";
  124.                     string mess = "";
  125.  
  126.                     flag += message[0];
  127.                     //////////////если сообщение/////////////
  128.                     if (flag == "m")
  129.                     {
  130.  
  131.                         richTextBox1.Text += "log: " + message + "\r\n";
  132.  
  133.                         for (int i = 1; i < message.Length; i++)
  134.                         {
  135.                             mess += message[i];
  136.                         }
  137.                         richTextBox1.Text += mess + "\r\n";
  138.                     }
  139.                     ///////////////если список/////////////
  140.                     if (flag == "l")
  141.                     {
  142.  
  143.                         richTextBox1.Text += "log: " + message + "\r\n";
  144.  
  145.                         for (int i = 1; i < message.Length; i++)
  146.                         {
  147.                             if (message[i] != ';')
  148.                             {
  149.                                 mess += message[i];
  150.                             }
  151.                             else
  152.                             {
  153.                                 listBox1.Items.Add(mess);
  154.                                 mess = "";
  155.                             }
  156.                         }
  157.                     }
  158.                     //////////////////если ушел кто-то////////////
  159.                     if (flag == "z")
  160.                     {
  161.  
  162.                         richTextBox1.Text += "log: " + message + "\r\n";
  163.  
  164.                         for (int i = 1; i < message.Length; i++)
  165.                         {
  166.                             mess += message[i];
  167.                         }
  168.                         listBox1.Items.Remove(mess);
  169.                     }
  170.                     ///////////////////если пришел кто-то////////////////
  171.                     if (flag == "a")
  172.                     {
  173.  
  174.                         richTextBox1.Text += "log: " + message + "\r\n";
  175.  
  176.                         for (int i = 1; i < message.Length; i++)
  177.                         {
  178.                             mess += message[i];
  179.                         }
  180.                         listBox1.Items.Add(mess);
  181.                     }
  182.  
  183.                 }
  184.                 catch
  185.                 {
  186.                    
  187.                 }
  188.             }
  189.             client.Close();
  190.  
  191.         }
  192.  
  193.         private static string ReadResponse(TcpClient clientkl) 
  194.         { 
  195.             byte[] buffer = new byte[256]; 
  196.             int totalRead = 0;
  197.             do 
  198.             { 
  199.                 int read = clientkl.GetStream().Read(buffer, totalRead, buffer.Length - totalRead); 
  200.                 totalRead += read; 
  201.  
  202.             }
  203.             while (clientkl.GetStream() .DataAvailable) ; 
  204.             return Encoding.Unicode.GetString(buffer, 0, totalRead); 
  205.         }
  206.  
  207.         private void button2_Click(object sender, EventArgs e)
  208.         {
  209.             string message = textBox3.Text;
  210.             SendMessage(clientkl,message,"m");
  211.             richTextBox1.Text += DateTime.Now.ToLongTimeString() + " " + NIK + ": " + message + "\r\n";
  212.             textBox3.Text = "";
  213.         }
  214.  
  215.         private void Form1_Load(object sender, EventArgs e)
  216.         {
  217.  
  218.         }
  219.  
  220.     }
  221. }
Проблема в том что при подключении нового клиента в списке users все перезаписывается им((((

Решение задачи: «.NET 2.x Многопользовательский чат на TcpClient»

textual
Листинг программы 
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5.  
  6. using System.Threading;
  7. using System.Net.Sockets;
  8. using System.Net;
  9. using System.Runtime.InteropServices;
  10.  
  11. namespace ConsoleApplication1
  12. {
  13.     class Program
  14.     {
  15.  
  16.         
  17.  
  18.         const int port=3128;
  19.         static public List<user> users = new List<user>();
  20.         
  21.         public static TcpListener listener;
  22.         
  23.         public static string host = Dns.GetHostName();
  24.         public static string myIp = Dns.GetHostByName(host).AddressList[0].ToString();
  25.         
  26.         static void Main(string[] args)
  27.         {
  28.             IPAddress localhost = IPAddress.Parse(myIp);
  29.             listener = new TcpListener(localhost, port);
  30.             listener.Start();
  31.             Console.WriteLine("Сервер запущен...");
  32.  
  33.             
  34.             Thread thread;
  35.             
  36.  
  37.             while (true)
  38.             {
  39.                 while (!listener.Pending())
  40.                 {
  41.                     Thread.Sleep(500);
  42.                 }
  43.  
  44.                 TcpClient client = new TcpClient();
  45.                 client =listener.AcceptTcpClient();
  46.                 thread = new Thread(new ParameterizedThreadStart(wordclient));
  47.                 thread.Start(client);
  48.             }
  49.         }
  50.  
  51.         static void wordclient(object obj)
  52.         {
  53.             TcpClient clientid = obj as TcpClient;
  54.             bool done = true;
  55.  
  56.             while (done)
  57.             {
  58.                 string message = ReadMessage(clientid);
  59.  
  60.                 string flag = "";
  61.                 string mess = "";
  62.  
  63.                 flag += message[0];
  64.                 //////////////если прислал сообщение////////
  65.                 if (flag == "m")
  66.                 {
  67.                     for (int i = 1; i < message.Length; i++)
  68.                     {
  69.                         mess += message[i];
  70.                     }
  71.  
  72.                     //Console.WriteLine(mess);
  73.                     SendMessageAll(clientid, mess, "m");
  74.                 }
  75.                 //////////////если прислал ник///////////////
  76.                 if (flag == "n")
  77.                 {
  78.                     for (int i = 1; i < message.Length; i++)
  79.                     {
  80.                         mess += message[i];
  81.                     }
  82.  
  83.                     var tmpuser = new user();
  84.  
  85.                     tmpuser.add(mess, clientid);
  86.                     users.Add(tmpuser);
  87.  
  88.                     SendMessageAll(clientid, mess, "a");
  89.                     mess = "";
  90.                     
  91.                     foreach (user tmp in users)
  92.                     {
  93.                         Console.WriteLine("Клиент подключен. IP:{0}   Ник:{1}", clientid.Client.RemoteEndPoint.ToString(), tmp.name);
  94.                         if(clientid!=tmp.klient)
  95.                             mess += tmp.name + ";";
  96.                     }
  97.  
  98.                     SendMessage(clientid, mess, "l");
  99.                 }
  100.                 ///////////////если отключился/////////////
  101.                 if (flag == "o")
  102.                 {
  103.                     for (int i = 1; i < message.Length; i++)
  104.                     {
  105.                         mess += message[i];
  106.                     }
  107.                     SendMessageAll(clientid, mess, "z");
  108.                     Console.WriteLine("Клиент отключен. IP:{0}    Ник:{1}", clientid.Client.RemoteEndPoint, mess);
  109.                     user tmp2 = new user();
  110.                     foreach (user tmp in users)
  111.                     {
  112.                         if (tmp.klient == clientid)
  113.                         {
  114.                             tmp2.add(tmp.name, tmp.klient);
  115.                         }
  116.                     }
  117.                     users.Remove(tmp2);
  118.  
  119.                     done = false;
  120.                 }
  121.             }
  122.             
  123.             clientid.Close();
  124.         }
  125.  
  126.         static string ReadMessage(TcpClient client)
  127.         {
  128.             byte[] buffer = new byte[256];
  129.             int totalRead = 0;
  130.             do
  131.             {
  132.                 int read = client.GetStream().Read(buffer, totalRead, buffer.Length - totalRead);
  133.                 totalRead += read;
  134.             } while (client.GetStream().DataAvailable);
  135.             return Encoding.Unicode.GetString(buffer, 0, totalRead);
  136.         }
  137.  
  138.         static void SendMessage(TcpClient client, string message, string flag)
  139.         {
  140.             flag += message;
  141.             byte[] bytes = Encoding.Unicode.GetBytes(flag);
  142.             client.GetStream().Write(bytes, 0, bytes.Length);
  143.         }
  144.  
  145.         static void SendMessageAll(TcpClient client, string message, string flag)
  146.         {
  147.             flag += message;
  148.             byte[] bytes = Encoding.Unicode.GetBytes(flag);
  149.             foreach (user tmp in users)
  150.             {
  151.                 if (tmp.klient!=client)
  152.                     tmp.klient.GetStream().Write(bytes, 0, bytes.Length);
  153.             }
  154.         }
  155.     }
  156.  
  157.     public class user
  158.     {
  159.         public string name;
  160.         public TcpClient klient;
  161.  
  162.         public void add(string aname, TcpClient aklient)
  163.         {
  164.             name = aname;
  165.             klient = aklient;
  166.         }
  167.     }
  168. }

ИИ поможет Вам:

  • решить любую задачу по программированию
  • объяснить код
  • расставить комментарии в коде
  • и т.д
Попробуйте бесплатно

Оцени полезность:

10   голосов , оценка 3.9 из 5

Нужна аналогичная работа?

Оформи быстрый заказ и узнай стоимость

Бесплатно
Оформите заказ и авторы начнут откликаться уже через 10 минут
Похожие ответы