Приложение мгновенного обмена сообщениями, как получить список друзей

int bytesRead = handler.EndReceive(ar);

chlog.WindowState = FormWindowState.Maximized;
chlog.Show();

chlog.Show();
chlog.WindowState = FormWindowState.Maximized;

//класс -пакет
class MySend
{
//определяем тип пакета
int type;
//данные, сообщение, логин-пароль
string message; 
}
....
//создаем сообщение
MySend  mes = new MySend();
mes.type=1;//пусть 1 - авторизация
mes.message = "login|pass"; //логин-пароль
//поток в память
System.IO.MemoryStream ms = new System.IO.MemoryStream();
XmlSerializer  xs = new XmlSerializer (typeof(MySend));
//сериализуем в память
xs.Serialize(ms, mes);
//получем строку сериализованного объекта
string str = Encoding.Default.GetString(ms.ToArray());
//отправляем на сервер
Send(str);

Console.ForegroundColor = ConsoleColor.Green;
Console.WriteLine("login and password true");
Console.ResetColor();
mes.type = 100;//100 - конект
mes.message = command; //логин
 
//поток в память
MemoryStream mse = new MemoryStream();
BinaryFormatter xse = new BinaryFormatter();
//сериализуем в память
xse.Serialize(mse, mes);
 
//получем строку сериализованного объекта
string str = Encoding.Default.GetString(ms.ToArray());
byte[] msg = Encoding.ASCII.GetBytes(str);
// Отправляем данные через сокет
int bytesSent = ClientSocket.Send(msg);

            byte[] bytes = new byte[1024];
 
            try
            {
                // устанавливаем удаленную конечну точку для скета
                IPHostEntry ipHost = Dns.Resolve("0.0.0.0");
                IPAddress ipAddr = ipHost.AddressList[0];
                IPEndPoint ipEndPoint = new IPEndPoint(ipAddr, 9050);
 
                Socket sender = new Socket(AddressFamily.InterNetwork, 
                                                SocketType.Stream, ProtocolType.Tcp);
 
                // соединяем сокет с удаленной конечной точкой
                sender.Connect(ipEndPoint);
 
                byte[] msg = Encoding.ASCII.GetBytes(mesg);
 
                // Отправляем данные через сокет
                int bytesSent = sender.Send(msg);
 
                // Получаем ответ от удаленного устройства
                int bytesRec = sender.Receive(bytes);
 
                //поток в память
                MemoryStream mse = new MemoryStream(bytes);
                BinaryFormatter xse = new BinaryFormatter();
                //десериализуем в память
                MySend mes = (MySend)xse.Deserialize(mse);
                mse.Close();
                mesd.Text = mes.message.ToString();
            }
            catch
            {
                //MessageBox.Show("error");
            }

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Net;
using System.Net.Sockets;
using System.Threading;
 
namespace ConsoleApplication1
{
    class Program
    {
        public static string theResponse = "";
        public static byte[] buffer = new byte[1024];
 
        public static ManualResetEvent ConnectDone = new ManualResetEvent(false);
        public static ManualResetEvent SendDone = new ManualResetEvent(false);
        public static ManualResetEvent ReceiveDone = new ManualResetEvent(false);
 
        static void Main(string[] args)
        {
            try
            {
                IPHostEntry ipHost = Dns.Resolve("0.0.0.0");
                IPAddress ipAddr = ipHost.AddressList[0];
                IPEndPoint endPoint = new IPEndPoint(ipAddr, 9050);
 
                Socket sClient = new Socket(AddressFamily.InterNetwork,
                    SocketType.Stream, ProtocolType.Tcp);
 
                sClient.BeginConnect(endPoint, new AsyncCallback(ConnectCallback), sClient);
 
                ConnectDone.WaitOne();
            }
            catch { }
        }
 
        public static void ConnectCallback(IAsyncResult ar)
        {
            Thread thr = Thread.CurrentThread;
 
            Socket sClient = (Socket)ar.AsyncState;
            sClient.EndConnect(ar);
 
            byte[] byteData = Encoding.ASCII.GetBytes(Console.ReadLine());
 
            sClient.BeginSend(byteData, 0, byteData.Length, 0,
                new AsyncCallback(SendCallback), sClient);
 
            ConnectDone.Set();
        }
 
        public static void SendCallback(IAsyncResult ar)
        {
            Thread thr = Thread.CurrentThread;
 
            Socket sClient = (Socket)ar.AsyncState;
 
            int byteSent = sClient.EndSend(ar);
 
            sClient.BeginReceive(buffer, 0, buffer.Length, 0,
                new AsyncCallback(ReceiveCallback), sClient);
 
            SendDone.Set();            
        }
 
        public static void ReceiveCallback(IAsyncResult ar)
        {
            Thread thr = Thread.CurrentThread;
 
            Socket sClient = (Socket)ar.AsyncState;
            
            int bytesRead = sClient.EndReceive(ar);
 
            if (bytesRead > 0)
            {
                theResponse += Encoding.ASCII.GetString(buffer, 0, bytesRead);
 
                sClient.BeginReceive(buffer, 0, buffer.Length, 0,
                    new AsyncCallback(ReceiveCallback), sClient);
            }
            else
            {
                ReceiveDone.Set();
            }
            Console.ReadKey();
        }
    }
}

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using MySql.Data.MySqlClient;
using Library;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Net.NetworkInformation;
using System.Runtime.Serialization.Formatters.Binary;
using System.Runtime.Serialization;
using System.IO;
 
namespace ServerSpeakPort
{
    class Mains
    {
        //переменные для подключения MySql
        public static string mysql_user = "root";
        public static string mysql_pass = "";
        public static string mysql_host = "localhost";
        public static string mysql_dbname = "sp";
 
 
        //переменные для идентификация пользователя
        public static string user_Login = "";
        public static string user_Pas = "";
        public static string user_Id = "";
 
        //буфер для получения и отправки данных
        public static byte[] buffer = new byte[1024];
 
        //класс события для поддержки синхронизации
        public static ManualResetEvent socketEvent = new ManualResetEvent(false);
 
        static void Main(string[] args)
        {
            IPHostEntry ipHost = Dns.Resolve(Dns.GetHostName());
            //IPHostEntry ipHost = Dns.Resolve("127.0.0.0");
            IPAddress ipAddr = ipHost.AddressList[0];
 
            IPEndPoint localEnd = new IPEndPoint(ipAddr, 9050);
            Console.ForegroundColor = ConsoleColor.Green;
            Console.WriteLine(ipAddr.ToString());
 
            Socket sListener = new Socket(AddressFamily.InterNetwork,
                SocketType.Stream, ProtocolType.Tcp);
 
            //связываем сокет
            sListener.Bind(localEnd);
 
            //начинаем слушать
            sListener.Listen(10);
 
            Console.WriteLine("Waiting for a connection...");
            Console.ResetColor();
 
            AsyncCallback aCallback = new AsyncCallback(AcceptCallback);
 
            //асинхронная функция, дающая согласие на соединения
            sListener.BeginAccept(aCallback, sListener);
 
            //ждем, пока другие потоки закончат работу
            socketEvent.WaitOne();
        }
 
        public static void AcceptCallback(IAsyncResult ar)
        {
            //сокет для получения запросов
            Socket listener = (Socket)ar.AsyncState;
 
            //новый сокет
            Socket handler = listener.EndAccept(ar);
 
            handler.BeginReceive(buffer, 0, buffer.Length, 0,
                new AsyncCallback(ReceiveCallback), handler);
        }
 
        public static void ReceiveCallback(IAsyncResult ar)
        {
            try
            {
                Socket ClientSocket = (Socket)ar.AsyncState;
                int bytesRead = ClientSocket.EndReceive(ar);                
 
                //если данные есть
                if (bytesRead > 0)
                {
                    //поток в память
                    MemoryStream ms = new MemoryStream(buffer);
                    BinaryFormatter xs = new BinaryFormatter();
                    //десериализуем в память
                    MySend mes = (MySend)xs.Deserialize(ms);
                    ms.Close();
 
                    switch (mes.type)
                    {
                        case 1: //Login
                            try
                            {
                                try
                                {
                                    int l = 0;
                                    for (int i = 0; i < mes.message.Length; i++)
                                    {
                                        if (mes.message[i] != '|')
                                        {
                                            l++;
                                        }
                                        else break;
                                    }
                                    for (int i = 0; i < l; i++)
                                    {
                                        user_Login = user_Login + mes.message[i];
                                    }
                                    for (int i = l + 1; i < mes.message.Length; i++)
                                    {
                                        user_Pas = user_Pas + mes.message[i];
                                    }
 
                                    string Connect = "Database=" + mysql_dbname + ";Data Source=" + mysql_host + ";User Id=" + mysql_user + ";Password=" + mysql_pass;
                                    MySqlConnection mysql_connect = new MySqlConnection(Connect);
 
                                    MySqlCommand mysql_query = new MySqlCommand("SELECT `username` FROM `users`;", mysql_connect);
 
                                    mysql_connect.Open();
 
                                    MySqlDataReader mysql_result;
                                    mysql_result = mysql_query.ExecuteReader();
 
                                    while (mysql_result.Read())
                                    {
                                        Console.WriteLine(mysql_result.GetString(0));
                                    }
 
                                    mysql_connect.Close();
 
                                    string command;
                                    command = user_Login;
                                    if (command != "")
                                    {
                                        mysql_query = new MySqlCommand("SELECT * FROM `users` WHERE `username`=\"" + command + "\";", mysql_connect);
                                        mysql_connect.Open();
                                        mysql_result = mysql_query.ExecuteReader();
                                        if (mysql_result.HasRows)
                                        {
                                            mysql_result.Read();
                                            if (mysql_result.GetString(0) != user_Login)
                                            {
                                                Console.ForegroundColor = ConsoleColor.Green;
                                                Console.WriteLine("error login");
                                                Console.ResetColor();
                                                mes.type = 101;//101 - нет такого юзера
                                                mes.message = "Нет такого юзера"; //логин-пароль чистим поле
 
                                                //поток в память
                                                MemoryStream mse = new MemoryStream();
                                                BinaryFormatter xse = new BinaryFormatter();
                                                //сериализуем в память
                                                xse.Serialize(mse, mes);
 
                                                //получем строку сериализованного объекта
                                                string str = Encoding.Default.GetString(ms.ToArray());
                                                byte[] msg = Encoding.ASCII.GetBytes(str);
                                                // Отправляем данные через сокет
                                                ClientSocket.BeginSend(msg, 0, msg.Length, 0,
                                                    new AsyncCallback(SendCallback), ClientSocket);
                                            }
                                            else
                                            {
                                                if (mysql_result.GetString(2) != user_Pas)
                                                {
                                                    Console.ForegroundColor = ConsoleColor.Green;
                                                    Console.WriteLine("error password");
                                                    Console.ResetColor();
                                                    mes.type = 102;//102 - неверный пароль
                                                    mes.message = "Неверный пароль"; //логин-пароль чистим поле
 
                                                    //поток в память
                                                    MemoryStream mse = new MemoryStream();
                                                    BinaryFormatter xse = new BinaryFormatter();
                                                    //сериализуем в память
                                                    xse.Serialize(mse, mes);
 
                                                    //получем строку сериализованного объекта
                                                    string str = Encoding.Default.GetString(ms.ToArray());
                                                    byte[] msg = Encoding.ASCII.GetBytes(str);
                                                    // Отправляем данные через сокет
                                                    ClientSocket.BeginSend(msg, 0, msg.Length, 0,
                                                        new AsyncCallback(SendCallback), ClientSocket);
                                                }
                                                else
                                                {
                                                    Console.ForegroundColor = ConsoleColor.Green;
                                                    Console.WriteLine("login and password true");
                                                    Console.ResetColor();
                                                    mes.type = 100;//100 - конект
                                                    mes.message = command; //логин
 
                                                    //поток в память
                                                    MemoryStream mse = new MemoryStream();
                                                    BinaryFormatter xse = new BinaryFormatter();
                                                    //сериализуем в память
                                                    xse.Serialize(mse, mes);
 
                                                    //получем строку сериализованного объекта
                                                    string str = Encoding.Default.GetString(ms.ToArray());
                                                    byte[] msg = Encoding.ASCII.GetBytes(str);
                                                    // Отправляем данные через сокет
                                                    ClientSocket.BeginSend(msg, 0, msg.Length, 0,
                                                        new AsyncCallback(SendCallback), ClientSocket);
                                                    break;
                                                }
                                            }
                                        }
                                        else
                                        {
                                            Console.ForegroundColor = ConsoleColor.Green;
                                            Console.WriteLine("not found");
                                            Console.ResetColor();
                                            mes.type = 103;//103 - пользователь с таким именем не найден
                                            mes.message = "Пользователь с таким именем не найден"; //логин-пароль чистим поле
 
                                            //поток в память
                                            MemoryStream mse = new MemoryStream();
                                            BinaryFormatter xse = new BinaryFormatter();
                                            //сериализуем в память
                                            xse.Serialize(mse, mes);
 
                                            //получем строку сериализованного объекта
                                            string str = Encoding.Default.GetString(ms.ToArray());
                                            byte[] msg = Encoding.ASCII.GetBytes(str);
                                            // Отправляем данные через сокет
                                            ClientSocket.BeginSend(msg, 0, msg.Length, 0,
                                                new AsyncCallback(SendCallback), ClientSocket);
                                        }
                                        mysql_connect.Close();
                                    }
                                }
                                catch
                                {
                                    Console.ForegroundColor = ConsoleColor.Green;
                                    Console.WriteLine("Ошибка MySQL");
                                    Console.ResetColor();
                                }
 
                            }
                            catch (Exception ex)
                            {
                                Console.WriteLine(ex.ToString());
                            }
                            break;
 
                        case 2://Privat message
                            try
                            {
 
                            }
                            catch (Exception ex)
                            {
                                Console.WriteLine(ex.ToString());
                            }
                            break;
                    }
                }
            }
            catch (Exception ex) { Console.WriteLine(ex.ToString()); }
        }
 
        public static void SendCallback(IAsyncResult ar)
        {
            Socket handler = (Socket)ar.AsyncState;
 
            //отправляем данные обратн клиенту
            int bytesSent = handler.EndSend(ar);
        }
    }
}

using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Text;
using System.Windows.Forms;
using System.Net;
using System.Net.Sockets;
using System.Threading;
using System.Runtime.Serialization.Formatters.Binary;
using System.Runtime.Serialization;
using System.IO;
using Library;
 
namespace ClientSpeakPort
{
    public partial class SpeakPort : Form
    {
        public SpeakPort()
        {            
            InitializeComponent();
        }
        
        private void speakPortToolStripMenuItem_Click(object sender, EventArgs e)
        {
            
            ListViewItem newItem = this.listView1.Items.Add("LoginName");
            newItem.ImageKey = "photo.gif";
            newItem.SubItems.Add("name");            
        }
 
        private void loginToolStripMenuItem_Click(object sender, EventArgs e)
        {
            Login login = new Login();
            login.Show();
        }
 
        public static string theResponse = "";
        public static byte[] buffer = new byte[1024];
 
        public static ManualResetEvent ConnectDone = new ManualResetEvent(false);
        public static ManualResetEvent SendDone = new ManualResetEvent(false);
        public static ManualResetEvent ReceiveDone = new ManualResetEvent(false);
 
        public static void Connect()
        {
            try
            {
                IPHostEntry ipHost = Dns.Resolve("127.0.0.0");
                IPAddress ipAddr = ipHost.AddressList[0];
                IPEndPoint endPoint = new IPEndPoint(ipAddr, 9050);
 
                Socket sClient = new Socket(AddressFamily.InterNetwork,
                    SocketType.Stream, ProtocolType.Tcp);
 
                sClient.BeginConnect(endPoint, new AsyncCallback(ConnectCallback), sClient);
 
                ConnectDone.WaitOne();
            }
            catch { }
        }
 
        public static void ConnectCallback(IAsyncResult ar)
        {
            Thread thr = Thread.CurrentThread;
 
            Socket sClient = (Socket)ar.AsyncState;
            sClient.EndConnect(ar);
 
            //Login.str.ToString() сериализовоная строка с type 1, message login|password
            byte[] byteData = Encoding.ASCII.GetBytes(Login.str.ToString());
 
            sClient.BeginSend(byteData, 0, byteData.Length, 0,
                new AsyncCallback(SendCallback), sClient);
 
            ConnectDone.Set();
        }
 
        public static void SendCallback(IAsyncResult ar)
        {
            Thread thr = Thread.CurrentThread;
 
            Socket sClient = (Socket)ar.AsyncState;
 
            int byteSent = sClient.EndSend(ar);
 
            sClient.BeginReceive(buffer, 0, buffer.Length, 0,
                new AsyncCallback(ReceiveCallback), sClient);
            //Console.WriteLine(buffer.ToString());
 
            //SendDone.Set();
        }
 
        public static void ReceiveCallback(IAsyncResult ar)
        {
            //Thread thr = Thread.CurrentThread;
 
            Socket sClient = (Socket)ar.AsyncState;
 
            int bytesRead = sClient.EndReceive(ar);
 
            if (bytesRead > 0)
            {
                //поток в память
                MemoryStream ms = new MemoryStream(buffer);
                BinaryFormatter xs = new BinaryFormatter();
                //десериализуем в память
                MySend mes = (MySend)xs.Deserialize(ms);
 
                switch (mes.type)
                {
                    case 100:
                        try
                        {
                            SpeakPort main = new SpeakPort();
                            main.Show();
                            main.Text = "Speak Port: " + mes.message.ToString();
                        }
                        catch { }
                        break;
                    case 101:
                        { }
                        break;
                }
                ms.Close();
                theResponse += Encoding.ASCII.GetString(buffer, 0, bytesRead);
                if (theResponse == "Anna")
                {
                    SpeakPort nn = new SpeakPort();
                    nn.Text = theResponse.ToString();
                }
                sClient.BeginReceive(buffer, 0, buffer.Length, 0,
      new AsyncCallback(ReceiveCallback), sClient);
            }
        }        
    }
}

//клиент
        private void exitToolStripMenuItem_Click(object sender, EventArgs e)
        {
            if (CONNECTED == true)
            {
                MeOff(true);
            }
            Application.Exit();
        }
....
private void MeOff(bool sl)
        {
            if (sl == true)
            {
                try
                {
                    MySend mes = new MySend();
                    mes.type = 110;
                    mes.message = "";
                    mes.fr_id = friendl;
                    MemoryStream mse_ = new MemoryStream();
                    BinaryFormatter xse_ = new BinaryFormatter();
                    xse_.Serialize(mse_, mes);
                    string str = Encoding.Default.GetString(mse_.ToArray());
                    mse_.Close();
                    byte[] message = Encoding.ASCII.GetBytes(str);
                    ClToSr.BeginSend(message, 0, message.Length, 0, new AsyncCallback(SendDataSr), ClToSr);                    
                    CONNECTED = false;
                    receiver_.Suspend();
                }
                catch (Exception e)
                {
                    MessageBox.Show(e.ToString());
                }
            }
        }

//сервер
        public void ReceiveCallback(object id)
        {
            int Clnm = (int)id;
            while (true)
            {
                byte[] data = new byte[1024];
 
                try
                {
                    int recv = user[Clnm].Receive(data);
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.ToString());
                }
                MemoryStream ms = new MemoryStream(data);
                BinaryFormatter xs = new BinaryFormatter();
                //десериализуем в память
                MySend mes = (MySend)xs.Deserialize(ms);
                ms.Close();
 
                string stData = mes.message, userNM = userlist[Clnm];
                switch (mes.type)
                {
                    case 110:
                        try
                        {
                            Console.WriteLine("\nПользователь \"" + userlist[Clnm] + "\" отключился.");
                            SendMeOff(Clnm, mes.fr_id);
                        }
                        catch (Exception e)
                        {
                            Console.WriteLine(e.ToString());
                        }
                        break;
                }
                Console.WriteLine("\nПользователь \"" + userNM + "\" отключился.");
                try
                {
                    user[Clnm].Close();
                }
                catch { }
            }
            user[Clnm] = null;
            userlist[Clnm] = null;
            return;
        }
....
private void SendMeOff(int ID,string frList)
        {
            try
            {
                MySend mes = new MySend();
                int k = 0, l = 0;
                string[] fr = new string[1000];
                string fr_ = "";
                string otName = userlist[ID];
 
                for (int i = 0; i < frList.Length; i++)
                {
                    if (frList[i] != ';')
                    {
                        k = k + 1;
                    }
                    else
                    {
                        for (int j = l; j < k; j++)
                        {
                            fr_ = fr_ + frList[j].ToString();
                        }
                        Console.Write(fr_ + " - ");
                        for (int r = 0; r < 1000; r++)
                        {
                            if (userlist[r] != null)
                            {
                                Console.WriteLine(r.ToString() + " ;");
                                if (fr_ == userlist[r])
                                {
                                    mes.type = 107;//107 - online send
                                    mes.message = otName; //логин  
                                    mes.status = 0; //status online
                                    MemoryStream mse = new MemoryStream();
                                    BinaryFormatter xse = new BinaryFormatter();
                                    xse.Serialize(mse, mes);
                                    string str = Encoding.Default.GetString(mse.ToArray());
                                    mse.Close();
                                    byte[] msg = Encoding.ASCII.GetBytes(str);
                                    user[r].BeginSend(msg, 0, msg.Length, 0,
                                        new AsyncCallback(SendCallback), user[r]);
                                }
                                Console.WriteLine(userlist[r]+"////");
                            }
                        }
                        fr[l] = fr_;
                        fr_ = "";
                        k = k + 1;
                        l = k;
                    }
                }
                user[ID] = null;
                userlist[ID] = null;
                return;
            }
            catch (Exception e)
            {
                Console.WriteLine(e.ToString());
            }
        }

 int bytesRead = ClientSocket.EndReceive(ar); 
 
if(bytesRead == 0 )  
{
//клиент отключился
}

        private void MeOff(bool sl)
        {
            if (sl == true)
            {
                try
                {
                    MySend mes = new MySend();
                    mes.type = 110;
                    MemoryStream mse_ = new MemoryStream();
                    BinaryFormatter xse_ = new BinaryFormatter();
                    xse_.Serialize(mse_, mes);
                    string str = Encoding.Default.GetString(mse_.ToArray());
                    mse_.Close();
                    byte[] message = Encoding.ASCII.GetBytes(str);
                    ClToSr.BeginSend(message, 0, message.Length, 0, new AsyncCallback(SendDataSr), ClToSr);
                    Thread.Sleep(100);
                    byte[] messag = new byte[0];
                    ClToSr.BeginSend(messag, 0, messag.Length, 0, new AsyncCallback(SendDataSr), ClToSr);
                    CONNECTED = false;                    
                }
                catch (Exception e)
                {
                    MessageBox.Show(e.ToString());
                }
            }
        }

        public void ReceiveCallback(object id)
        {
            int Clnm = (int)id;
            while (true)
            {
                bool st = false;
                byte[] data = new byte[1024];
                int recv = user[Clnm].Receive(data);
                if (recv != 0)
                {
                    MemoryStream ms = new MemoryStream(data);
                    BinaryFormatter xs = new BinaryFormatter();
                    //десериализуем в память
                    MySend mes = (MySend)xs.Deserialize(ms);
                    ms.Close();
 
                    string stData = mes.message, userNM = userlist[Clnm];
                    switch (mes.type)
                    {
                        case 110:
                            try
                            {
                                Console.WriteLine("ZDFASDF ------");
                                string frl = friendlist[Clnm];
                                SendMeOff(Clnm, frl);
                                st = true;
                            }
                            catch (Exception e)
                            {
                                Console.WriteLine("case 110 " + e.ToString());
                            }
                            break;
                    }
                    Console.WriteLine("\nПользователь \"" + userNM + "\" отключился.");
                    if (st == true)
                    {
                        break;
                    }

//сервер
            IPHostEntry ipHost = Dns.Resolve(Dns.GetHostName());
            IPAddress ipAddr = ipHost.AddressList[0];
            IPEndPoint localEnd = new IPEndPoint(ipAddr, 4505);
            Socket sListener = new Socket(AddressFamily.InterNetwork,
                SocketType.Stream, ProtocolType.Tcp);
            //связываем сокет
            sListener.Bind(localEnd);
            //начинаем слушать
            sListener.Listen(1000);