0

Здравствуйте, написал некоторое клиент-серверное приложение в котором: 1) Клиент отправляет запрос(просто отправляю в данном примере "SELECT") 2) Сервер в ответ на это отправляет некоторую xml сериализацию обьекта класса Person(в будущем предпологается, что я буду с EntityFramework-а(бд) вытягивать некоторый спектр обьектов по запросу и передавать их клиенту)(пока это неважно). Server code:

class Program
{
    private static Socket server = new Socket(AddressFamily.InterNetworkV6,SocketType.Stream,ProtocolType.Tcp);
    // private static List<Socket> clients;

    private static List<Person> persons = new List<Person>()
    {
        new Person(0,18,"Sergey 1111"),
        new Person(1,30,"1111 Maksim"),
        new Person(2,20,"Pasha 1111"),
        new Person(3,27,"4444 Ivanov")
    };

    static void Main(string[] args)
    {
        StartServer();
        Console.ReadLine();
    }

    public static void StartServer()
    {
        try
        {
            IPEndPoint end = new IPEndPoint(IPAddress.Parse("***::***:***:***:***%***"), 8005);
            server.Bind(end);

            server.Listen(10);
            Console.WriteLine("> server {0} has started", end);
            server.BeginAccept(AcceptCallback,null); 
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }

    public static void AcceptCallback(IAsyncResult ar)
    {
        Socket client = server.EndAccept(ar); 
        Thread thread = new Thread(HandleClient);
        thread.Start(client);
        server.BeginAccept(AcceptCallback, null);
    }
    public static void HandleClient(object o)
    {
        try
        {


            Socket client = (Socket)o;
            byte[] buffer = new byte[256];
            MemoryStream ms = new MemoryStream(new byte[256], 0, 256, true, true);
            BinaryReader reader = new BinaryReader(ms);
            BinaryWriter writer = new BinaryWriter(ms);
            while (true)
            {
                ms.ClearMemory();

                client.Receive(ms.GetBuffer());


                string cmd = reader.ReadString();
                Console.WriteLine("> {0}", cmd);
                ms.ClearMemory();

                switch (cmd)
                {
                    case "SELECT": { SendQueryResult(client); break; }
                };

                writer.Write("server> Message sent");
                client.Send(ms.GetBuffer());


            }
        }catch(Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }

    public static void SendQueryResult(object o)
    {
        List<string> query_result = new List<string>();
        Socket client = (Socket)o;
        MemoryStream ms = new MemoryStream(new byte[512], 0, 512, true, true);
        BinaryReader reader = new BinaryReader(ms);
        BinaryWriter writer = new BinaryWriter(ms);
        ms.ClearMemory();
        foreach(Person p in persons)
        {
            query_result.Add(p.Serialize());
        }

        foreach(string xml in query_result)
        {
            ms.ClearMemory();
            writer.Write(xml);
            client.Send(ms.GetBuffer());
        } 
    }

    public static bool SocketConnected(Socket s)
    {
        bool part1 = s.Poll(1000, SelectMode.SelectRead);
        bool part2 = (s.Available == 0);
        if (part1 && part2)
            return false;
        else
            return true;
    }
}

public static class EMethods
{
    public static void ClearMemory(this MemoryStream stream)
    {
        Array.Clear(stream.GetBuffer(), 0, stream.GetBuffer().Length);
        stream.Position = 0;
    }

    public static string Serialize<T>(this T value)
    {
        if (value == null)
        {
            return string.Empty;
        }
        try
        {
            var xmlserializer = new XmlSerializer(typeof(T));
            var stringWriter = new StringWriter();
            using (var writer = System.Xml.XmlWriter.Create(stringWriter))
            {
                xmlserializer.Serialize(writer, value);
                return stringWriter.ToString();
            }
        }
        catch (Exception ex)
        {
            throw new Exception("An error occurred", ex);
        }
    }
}

Client code:

class Program
{
    private static string querydata = "EMPTY";
    private static List<XmlDocument> xml_results = new List<XmlDocument>();

    private static Socket socket = new Socket(AddressFamily.InterNetworkV6, SocketType.Stream, ProtocolType.Tcp);
    private static MemoryStream ms = new MemoryStream(new byte[256], 0, 256, true, true);
    private static BinaryWriter writer = new BinaryWriter(ms);
    private static BinaryReader reader = new BinaryReader(ms);

    static void Main(string[] args)
    {
        IPEndPoint IPend = new IPEndPoint(IPAddress.Parse(""***::***:***:***:***%***""), 8005);
        socket.Connect(IPend);
        Console.WriteLine("> successfully connected to {0}", IPend);

        while (true)
        {

            Console.Write("cmd> ");
            string cmd = Console.ReadLine();

            //MemoryStream m_stream = new MemoryStream(buffer);
          //  BinaryWriter b_writer = new BinaryWriter(m_stream);

            switch (cmd)
            {
                case "exit": { return; }
                case "select":
                    {
                        querydata = "SELECT";
                        break;
                    }
                case "create":
                    {
                        querydata = "CREATE";
                        break;
                    }
                case "update":
                    {
                        querydata = "UPDATE";
                        break;
                    }
                case "delete":
                    {
                        querydata = "DELETE";
                        break;
                    }
            };
            List<string> query_result = new List<string>();

            SendPacket(querydata);

            while(true)
            {
                string result = ReceivePacket();
                if(result == "server> Result sent" || result == "server> Message sent") { break; }
                else
                {
                    query_result.Add(result);
                }
            }

            foreach(var xml_str in query_result)
            {
                XmlDocument document = new XmlDocument();
                document.LoadXml(xml_str);
                xml_results.Add(document);
            }
            ViewXMLResult(xml_results);
            xml_results.Clear();
            query_result.Clear();
        }
    }

    public static void ViewXMLResult(List<XmlDocument> list)
    {
        foreach(var doc in list)
        {
            XmlElement elem = doc.DocumentElement;
            XmlNode node = elem.SelectSingleNode("PersonID");
            XmlNode node1 = elem.SelectSingleNode("Age");
            XmlNode node2 = elem.SelectSingleNode("FullName");
            Console.WriteLine("Xml ID = {0} \nXml Age = {1} \nXml FullName = {2}", node.InnerText, node1.InnerText, node2.InnerText);
            Console.WriteLine();
        }
    }


    public static void ConnectToServer(Socket sock, IPEndPoint end)
    {
        try
        {
            sock.Connect(end);
            Console.WriteLine("> successfully connected to {0}", end);

        } catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
    }

    public static void SendPacket(string data)
    {
        ms.ClearMemory();
        writer.Write(data);
        socket.Send(ms.GetBuffer());
    }

    public static string ReceivePacket()
    {
        ms.ClearMemory();
        socket.Receive(ms.GetBuffer());
        string message = reader.ReadString();
        Console.WriteLine(message);

        return message;
    }
}

public static class EMethods
{
    public static void ClearMemory(this MemoryStream stream)
    {
        Array.Clear(stream.GetBuffer(), 0, stream.GetBuffer().Length);
        stream.Position = 0;
    }
}

У меня возникает некоторая проблема при получении данных на клиенте. На сервере я спокойно получаю список сериализованых обьектов(в виде строки в которой xml) и передаю их клиенту. На клиенте получаю все данные, но кроме того между переданными данными клиент получает пустую строку. То есть 1ю xml строку я на клиенте получаю все окей, почему то потом клиент получает ""(пустую строку) и дальше получает нормальный обьект. Грубо говоря результат на клиенте получается в таком виде 1)xml1 2)"" 3)xml2 4)"" 5)xml3 6)"" 7)xml4. То есть я то получаю все 4е xml, но так же получаю пустые строки, уже какой час сижу не могу найти свою ошибку, может кто увидит пустую строку которую я передаю?

1 ответ 1

0

Скорее всего таким образом сериализуется перенос строки. Нужно сделать настройки чтото подобно этому:

XmlWriterSettings settings = new XmlWriterSettings();
settings.NewLineHandling = NewLineHandling.None;
5
  • Дело в том, что после сериализации в списке xml строк, нету ничего похожего на перенос строки. Получается я отправляю 4 строки с листа(то есть отправляю 4е раза, в это время клиент должен принять 4 раза, а почему то принимает 3 доп. раза. Я поставил задержку в пол секунды в цикле получения данных с сервера, тот же результат. В общем я еще не попробовал твой способ, но по идее ничего не произойдет, так как пробелов\символов переноса строки там нету. 6 сен 2017 в 15:36
  • В общем мне в голову приходит только делать костыль, который обрабатывает выходной список и удаляет все пустые строки. Такое ощущение, что сервер после отправки строки повторно отправляет пустую строку, то есть пустой буфер, но я не могу нормально это задебажить, слишком нуб. 7 сен 2017 в 10:45
  • Нашел проблему. Это на клиенте. При отправке на сервер метод Send отправляет 4е раза, а метод Receive на клиенте принимает 8 раз.(3 пустые страки+сообщение об конце отправки). Терь надо думать как правильнее всего синхронизировать отправку и прием данных 7 сен 2017 в 11:37
  • В общем проблема в цикле в котором я запускаю прием все обьектов по отдельности. Клиент что ли слишком быстро просит на прием данные и получает пустую строку. Хотя если бы дело было в скорости, то Thread.Sleep() помог бы, но он не помогает. Буду думать дальше 7 сен 2017 в 11:47
  • Дружеский совет: Если ваш проект собирается развиваться, то лучше сразу откажитесь от собственной реализации сокетов, и используйте WCF 9 сен 2017 в 8:23

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.