VPF::TCP Socket и прием смешанных данных

lifespirit

Дата 16.5.2011, 23:53 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 2
Регистрация: 16.5.2011

Репутация: нет
Всего: нет

Есть программа, принимающая данные от клиента по порту 25565. Клиент высылает данные в специальном виде: первый байт - код пакета, второй + третий байт - длинна строки, третий и последующие байты - строка. Вот пример: 2 0 a 0 6c 0 69 0 66 0 65 0 73 0 70 0 69 0 72 0 69 0 74. Код пакета 2, длинна строки A (10), а дальше идет текст (lifespirit) в виде байт таблицы символов. Проблема в том, что мне нужно каким то образом превратить байты теста в char[], который можно сравнить с ответом MySQL сервера на запрос из таблицы. Плюс к этому помимо английского текста строка может оказаться заполненной русскими буквами, а это значит что нельзя убирать двухбайтность символа (потому что русские буквы кодируются двумя байтами где первый байт 04, а второй байт - байт символа).
Вот код Stream:

Код


#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <netinet/in.h>
#include <stdio.h>
#include <unistd.h>
#include <fcntl.h>
#include <algorithm>
#include <set>
using namespace std;

int main()
{
    int listener;
    struct sockaddr_in addr;
    char buf[1024];
    char buf_wright[1024];
    int bytes_read;
    int bytes_wright;
    
    listener = socket(AF_INET, SOCK_STREAM, 0); //создаем интернет потоковый сокет
    if(listener < 0)
    {
        perror("socket");
        exit(1);
    }
    
    fcntl(listener, F_SETFL, O_NONBLOCK);
    
    addr.sin_family = AF_INET;
    addr.sin_port = htons(25565);
    addr.sin_addr.s_addr = INADDR_ANY;
    if(bind(listener, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
        perror("bind");
        exit(2);
    }

    listen(listener, 2);
    
    set<int> clients;
    clients.clear();

    while(1)
    {
        // Заполняем множество сокетов
        fd_set readset;
        FD_ZERO(&readset);
        FD_SET(listener, &readset);

        for(set<int>::iterator it = clients.begin(); it != clients.end(); it++)
            FD_SET(*it, &readset);

        // Задаем таймаут
        timeval timeout;
        timeout.tv_sec = 200;
        timeout.tv_usec = 0;

        // Ждем события в одном из сокетов
        int mx = max(listener, *max_element(clients.begin(), clients.end()));
        if(select(mx+1, &readset, NULL, NULL, &timeout) <= 0)
        {
                printf("NET_ERROR_MSG: Порт отвалился\n");
            exit(3);
        }
        
        // Определяем тип события и выполняем соответствующие действия
        if(FD_ISSET(listener, &readset))
        {
            // Поступил новый запрос на соединение, используем accept
            int sock = accept(listener, NULL, NULL);
            if(sock < 0)
            {
                perror("accept");
                exit(3);
            }
            
            fcntl(sock, F_SETFL, O_NONBLOCK);

            clients.insert(sock);
        }

        for(set<int>::iterator it = clients.begin(); it != clients.end(); it++)
        {
            if(FD_ISSET(*it, &readset))
            {
                // Поступили данные от клиента, читаем их
                bytes_read = recv(*it, buf, 1024, 0);
                printf("=======================\n");
                printf("NET_MSG_PORT: %d\nNET_MSG_BYTES: %d\nNET_MSG:", addr.sin_port, bytes_read);
                if(bytes_read <= 0)
                {
                    // Соединение разорвано, удаляем сокет из множества
                    printf("Соединение разорвано");
                    printf("\n=======================\n");
                    close(*it);
                    clients.erase(*it);
                    continue;
                }
                else
                {
                    //выводим на экран все байты буфера
                    for (int i = 0; i<bytes_read; i++) 
                    {
                        printf("%x   ", buf[i]);
                    }
                    printf("\n=======================\n");
                }
            }
        }
    }
   
    return 0;
}

Вот код MySQL обработчика:

Код


// для правильной работы библиотеки необходим: sudo apt-get install mysql-server mysql-client libmysqlclient12-dev
#include <stdio.h>
#include <stdlib.h>
#include <mysql/mysql.h>
#include <iostream>
using namespace std;
//задаем переменные MySQL
MYSQL mysql;
MYSQL_RES *res;
MYSQL_ROW row;

void exiterr(int exitcode);

int main(){
     //инициализируем обращение к mysql
    mysql_init(&mysql);    
     //прописываем логин и пароль
    if(!mysql_real_connect(&mysql, "localhost", "%username%", "%passwrd%", "%database%", 0, 0, 0))
        exiterr(1);
         //выбираем базу данных
    if (mysql_select_db(&mysql,"%database%")) exiterr(2); 
   //выбираем столбцы для таблицы
   if (mysql_query(&mysql,"SELECT login FROM login_table"))   
      exiterr(3);
   
   if (!(res = mysql_store_result(&mysql)))
      exiterr(4);
   //выводим значения таблицы в цикле
   while((row = mysql_fetch_row(res))) {                        
      for (int i=0 ; i < mysql_num_fields(res); i++)
         printf("%s\n",row[i]);
   }
   
   if (!mysql_eof(res))
      exiterr(5);
   mysql_free_result(res);
   //закрываем обращение к mysql
    mysql_close(&mysql);         
    return 0;
}
//===============================================================================
void exiterr(int exitcode){
// fprintf(stderr, "%s\n", mysql_error(&mysql)); Си вариант
std::cout << mysql_error(&mysql)<<"\n";
exit(exitcode);
}

Таблица при отработке своего кода честно выводит строку (lifespirit), которая не может вывестись с помощью printf("%x", row[i]); программа же, принимающая данные может выводить свою строку хоть в десятичном, хоть 16-ричном виде, но ничего не покажет по запросу printf("%s",buff);. Мне нужно:
1. Как то сравнить сидержимое row[i] и ту часть buff, в которой зашифрована строка, при этом желательно все же представить текстовую часть buf в виде строки
2. Если это невозможно, то хотя бы сравнить в любом состоянии buff и row[i].
Я пока что не вижу другого выхода кроме как написать функцию перевода бвухбайтовых чисел в буквы, но эта функция будет очень тяжелой для компьютера и не очень надежной (не все символы переведуться). Можно ли реализовать 1 или 2 средствами C++?
P.S.
Использую компилятор g++ под linux'ом. MySQL код собираю командой "g++ -omysql mysqlserv.cpp -lmysqlclient"

Это сообщение отредактировал(а) lifespirit - 16.5.2011, 23:59

bsa

Дата 17.5.2011, 10:47 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Модератор
Сообщений: 9185
Регистрация: 6.4.2006
Где: Москва, Россия

Репутация: 85
Всего: 196

сделай преобразование в utf-8

--------------------

Правильно заданный вопрос - половина ответа
Отзывы о работе модератора.

xvr

Дата 17.5.2011, 11:49 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Комодератор
Сообщений: 7046
Регистрация: 28.8.2007
Где: Дублин, Ирландия

Репутация: 35
Всего: 223

Во первых - вам надо распарсить данные из сокета и выделить строку (и она будет в wchar_t, а не в char). Строку можно сложить в std::wstring. Так же учтите, что данные из recv совсем не обязательно будут приходить нарезанные строго по границам пакетов, границы вам придется восстанавливать самому.
Во вторых, надо принятую стоку привести к той же кодировке, что возвращает mysql. А они могут быть самые разные.
А потом уже можно сравнивать

lifespirit

Дата 17.5.2011, 23:31 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 2
Регистрация: 16.5.2011

Репутация: нет
Всего: нет

xvr, а можно поподробнее? И если не тяжело то в коде, а то я новичок, мало что понял. А насчет пакетов. клиент шлет очень маленькие ответы, они влазят в 1 пакет TCP 100%, а сервер может резать свой ответ как хочет. На стороне клиента восстановление пакетов давно реализовано. Благо этим занимаюсь не я. smile

Это сообщение отредактировал(а) lifespirit - 17.5.2011, 23:31

xvr

Дата 18.5.2011, 11:37 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Комодератор
Сообщений: 7046
Регистрация: 28.8.2007
Где: Дублин, Ирландия

Репутация: 35
Всего: 223

Цитата(lifespirit @ 17.5.2011, 23:31

)

И если не тяжело то в коде, а то я новичок, мало что понял.

Кода будет довольно много, так что я пожалуй его писать не буду smile

Цитата(lifespirit @ 17.5.2011, 23:31

)

А насчет пакетов. клиент шлет очень маленькие ответы, они влазят в 1 пакет TCP 100%,

Порезать и/или склеить пакеты может уже сама ОС (Windows). Так что надо быть готовым к тому, что из recv придет нечто, из чего пакеты придется извлекать.

Вот набросок обработчика пакета:

Код


class PktProcess {
 enum State {
   S_Idle,
   S_PktLen0,
   S_PktLen1,
   S_PktBody0,
   S_PktBody1
 } state;
 int acc;
 std::wstring data;
 int rest;
 int pkt_type;
public:
 PktProcess() {acc=0; state=S_Idle; data=L"";}

 virtual void pkt_recieved(int type, const std::wstring& body) =0;

 void add_byte(int b)
  {
   switch(state)
    {
     case S_Idle:     pkt_type=b; state=S_PktLen0; break;
     case S_PktLen0:  acc=b; state=S_PktLen1; break;
     case S_PktLen1:  acc|=b<<8; state=S_PktBody0; rest=acc; break;
     case S_PktBody0: acc=b<<8; state=S_PktBody1; break;
     case S_PktBody1: acc|=b; data+=wchar_t(acc); 
                      if (rest--) state=S_PktBody0; else
                       {
                        pkt_recieve(pkt_type,data); 
                        data=L""; 
                        state=S_Idle; 
                       }
                      break;
    }
  }
};

На каждый принятый через recv байт вызываете PktProcess::add_byte, когда объект наберет полный пакет, он вызовет метод pkt_recieved с типом пакета и принятой Unicode строкой

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| C/C++: Для новичков \| Следующая тема »