C/C++. Таймер с ожиданием внешней реакции

Как во время отсчета таймера параллельно ожидать реакции от пользователя (нажатие клавиши на клавиатуре) для инициирования других действий?

Есть такая функция в библиотеке <conio.h> - int kbhit(void), которая возвращает ненулевое значение, если клавиша нажата и возвращает 0, если не нажата.

Ниже приведен листинг, реализующий таймер с отрицательным отсчетом и при этом ожидающий нажатия любой кнопочки.

Обновление показателя счетчика таймера происходит путем возврата каретки и перезаписи предыдущего значения. По-сути - simple animation :)

Основа таймера зиждиться на функции Sleep(int miliseconds) библиотеки <windows.h>

#include <conio.h>
#include <stdio.h>
#include <windows.h>

int main() {

    // Счетчик для таймера
    int count = 10;
    //    Для проверки нажатия клавиши клавиатуры
    int result;
    // Флаг вывода сообщения о типе остановки таймера
    bool showIt = true;

   
    printf("Press any key to stop timer\n");
    // Для обновления вывода таймера воспользуемся возвратом каретки \r
    printf("10\r");

    while(count >= 0) {
       
        // Проверка нажатия клавиши клавиатуры. При нажатии возвращает ненулевое значение, иначе - return 0
        if(result = kbhit()) {
            printf("Таймер остановлен вручную\n");
            showIt = false;
            break;
        }

        count--;
        // Ожидание в 1 секунду
        Sleep(1000);
        printf("%d \r", count);               
    }

    if(showIt) {
        printf("Таймер остановлен автоматически\n");
    }

}

C/C++. Сетевое программирование. Создание веб-сервера. Часть 3

Очередная модель простейшего веб - сервера на основе Winsock. Только теперь в ответ клиенту отправляется не текстовый, а графический контент в виде gif - изображения (бинарный режим). Нижеприведенный листинг можно скачать по ссылке - download.

 


#undef UNICODE

#define WIN32_LEAN_AND_MEAN

#include <io.h>
#include <fcntl.h>

#include <windows.h>
#include <winsock2.h>
#include <ws2tcpip.h>
#include <stdlib.h>
#include <stdio.h>


// Need to link with Ws2_32.lib
#pragma comment (lib, "Ws2_32.lib")
// #pragma comment (lib, "Mswsock.lib")

// Размер буфера для приема данных веб-сервером (http-запросы)
#define DEFAULT_BUFLEN 512
// Зарезирвированный за HTTP протоколом номер порта
#define DEFAULT_PORT "80"

// Для определения размера gif-изображения
long filesize(FILE *f) {
  long pos, size;
  pos = ftell(f);
  fseek(f, 0, 2);
  size = ftell(f);
  fseek(f, pos, 0);
  return size;
}


int __cdecl main(void)
{
    // Буфер для отправки gif-изображения. Bynary content
    char *buffer;
    // Буфер для отправки в конечном виде ответа веб - сервера
    char response[256] = {0};
    // Размер содержимого ответа в буфере response
    int sizeResponse;
    // Для перевода значения размера gif-изображения из целочисленной в символьную строку
    char charSizeImage[10] = {0};
    // Счетчик для поиска размера содержимого ответа в буфере response
    int index = 0;
    // Проверочный счетчик при чтении в бинарном режиме содержимого потока f
    int count;

    // Открываем поток в бинарном режиме
    FILE *f = fopen("C://test.gif", "rb");

    // Определяем размер gif-изображения
    int sizeImage = filesize(f);

    // Выводим на консоль веб - сервера найденное значение размера gif-изображения
    printf("sizeImage is %d\n", sizeImage);
   
    // Переводим значение размера gif-изображения из целочисленной в символьную строку   
    itoa(sizeImage, charSizeImage, 10);

    // Выделяем память для буфера buffer
    buffer = new char[sizeImage];

    // Считываем данные из потока f в буфер buffer. Небольшая проверка: count содержит         считанное количество байт из патока f
    count = fread(buffer, 1, sizeImage, f);
    if(count != sizeImage) {
        printf("Error in fread(buffer, 1, sizeImage, f). Result = %d\n", count);
    }

    // Формирование ответа веб-сервера с соответствующими заголовками
    char status[] = "HTTP/1.1 200 OK\r\n";
    char pragma[] = "Pragma: no-cache\r\n";             
    char contentType[] = "ContentType = image/gif\r\n";            
    char contentLength[] = "Content-length:";
    char rn[] = "\r\n";

    // Проводим конкатенацию соответствующих заголовков в response согласно правилам Internet Request For Comment (RFC)
    strcat(response, status);
    strcat(response, pragma);
    strcat(response, contentType);
    strcat(response, contentLength);
    strcat(response, charSizeImage);
    strcat(response, rn);
    strcat(response, rn);

    // Определяем размер sizeResponse содержимого ответа в буфере response
    while(true) {
        if(response[index] == NULL) {
            sizeResponse = index;
            break;
        }
        index++;
    }

    /*
        Инициализация WinSock
                                */

    WSADATA wsaData;
    // Для хранения количества принятых данных (байты)
    int iResult;
    // Инициализируем соответствующие сокеты
    SOCKET ListenSocket = INVALID_SOCKET;
    SOCKET ClientSocket = INVALID_SOCKET;

    // Инициализируем соответствующую структуру для работы веб-сервера
    struct addrinfo *result = NULL;
    struct addrinfo hints;
   
    // Инициализируем структуру для последующего определения обращающихся на веб-сервер клиентов
    sockaddr_in name;
    int name_size = sizeof(name);
    // Обязательное обнуление элементов структуры
    ZeroMemory(&name, sizeof(name));

    // Для хранения количества оправленных данных (байты)
    int iSendResult;
    // Буфер для приема данных веб-сервером (http-запросы)
    char recvbuf[DEFAULT_BUFLEN];
    int recvbuflen = DEFAULT_BUFLEN;
   
    // Initialize Winsock
    iResult = WSAStartup(MAKEWORD(2,2), &wsaData);
    if (iResult != 0) {
        printf("WSAStartup failed with error: %d\n", iResult);
        return 1;
    }
   
    // Обязательное обнуление элементов структуры
    ZeroMemory(&hints, sizeof(hints));
    hints.ai_family = AF_INET;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_protocol = IPPROTO_TCP;
    hints.ai_flags = AI_PASSIVE;

    // Resolve the server address and port
    iResult = getaddrinfo(NULL, DEFAULT_PORT, &hints, &result);
    if ( iResult != 0 ) {
        printf("getaddrinfo failed with error: %d\n", iResult);
        WSACleanup();
        return 1;
    }

    // Create a SOCKET for connecting to server
    ListenSocket = socket(result->ai_family, result->ai_socktype, result->ai_protocol);
    if (ListenSocket == INVALID_SOCKET) {
        printf("socket failed with error: %ld\n", WSAGetLastError());
        freeaddrinfo(result);
        WSACleanup();
        return 1;
    }

    // Setup the TCP listening socket
    iResult = bind( ListenSocket, result->ai_addr, (int)result->ai_addrlen);
    if (iResult == SOCKET_ERROR) {
        printf("bind failed with error: %d\n", WSAGetLastError());
        freeaddrinfo(result);
        closesocket(ListenSocket);
        WSACleanup();
        return 1;
    }

    freeaddrinfo(result);

    iResult = listen(ListenSocket, SOMAXCONN);
    if (iResult == SOCKET_ERROR) {
        printf("listen failed with error: %d\n", WSAGetLastError());
        closesocket(ListenSocket);
        WSACleanup();
        return 1;
    }

    // Accept a client socket
    ClientSocket = accept(ListenSocket, NULL, NULL);
    if (ClientSocket == INVALID_SOCKET) {
        printf("accept failed with error: %d\n", WSAGetLastError());
        closesocket(ListenSocket);
        WSACleanup();
        return 1;
    }

    // Определяем IP-адрес клиента, постучившегося на веб-сервер
    getsockname(ClientSocket, (sockaddr*)&name, &name_size);
    // Выводим на консоль сервера
    printf("Client IP-adress: %s\n", inet_ntoa((in_addr)name.sin_addr));

    // No longer need server socket
    closesocket(ListenSocket);

    // Receive until the peer shuts down the connection
    // Принимаем данные
    iResult = recv(ClientSocket, recvbuf, recvbuflen, 0);

    if (iResult > 0) {
        printf("Bytes received: %d\n", iResult);
        printf ("%s\n", recvbuf);
        printf ("%s\n", "Insert for debug...");
       
        //Сначало передаем http-ответ браузеру и только потом соответствующий content
        send(ClientSocket, response, sizeResponse, 0 );
        printf("%s\n", response);

        iSendResult = send(ClientSocket, buffer, sizeImage, 0 );
        printf("%s\n", buffer);
       
        if (iSendResult == SOCKET_ERROR) {
            printf("send failed with error: %d\n", WSAGetLastError());
            closesocket(ClientSocket);
            WSACleanup();
            return 1;
        }
       
        printf("Bytes sent: %d\n", iSendResult);
       
    }
    else if (iResult == 0)
        printf("Connection closing...\n");
    else  {
        printf("recv failed with error: %d\n", WSAGetLastError());
        closesocket(ClientSocket);
        WSACleanup();
        return 1;
    }


    // shutdown the connection since we're done
    iResult = shutdown(ClientSocket, SD_SEND);
    if (iResult == SOCKET_ERROR) {
        printf("shutdown failed with error: %d\n", WSAGetLastError());
        closesocket(ClientSocket);
        WSACleanup();
        return 1;
    }

    // cleanup
    closesocket(ClientSocket);
   
    delete buffer;

    WSACleanup();

    return 0;
}

Есть только одна загвоздка. Отправка больших объемов данных не по зубам - Internet Explorer (тестировал на версии 8), в отличии от - Firefox, Opera, Safari. 

C/C++. Преобразование типов переменных: int to char or char to int

1. Подключаем библиотеку <stdlib.h>


2. Преобразование численной строки в символьную:

char *itoa( int value,  char *string, int radix ); 

char *ltoa( long value, char *string, int radix); 

char *ultoa( unsigned long value, char*string, int radix );

под radix понимают основание преобразуемого числа int value в символьную строку

char *string. 

Example:

#include <iostream>

#include <stdlib.h>

using namespace std;
int main()
{
        char *str = new char[17];

        int i = 1234567890;

        itoa(i, str, 10);

        cout << str << endl;

        delete szString;

        return 0;
}

3. Преобразование символьной строки в числовую:

double atof( char *string );

int atoi( char *string ); 

long atol( char *string );

long double _atold( char *string );

Example:

#include <iostream> 

#include <stdlib.h>

using namespace std;
int main()
{
        char * str = "0123456789";

        int i;

        i = atoi(str);

        cout << i << endl:

        return 0;
} 

Выше приведенные способы относят к нестандартным расширениям языка С, дело

принципа и специфики поставленной задачи. Поэтому для этих целей можно

воспользоваться стандартными C-шными функциями, например -

int sprintf ( char * str, const char * format, ... );

Вот пример.

/* sprintf example */
#include <stdio.h>

int main ()
{
  char buffer [50];
  int n, a=5, b=3;
  n=sprintf (buffer, "%d plus %d is %d", a, b, a+b);
  printf ("[%s] is a %d char long string\n",buffer,n);
  return 0;
} 

C. Сетевое программирование. Simple client for Unix

 Небольшое приложенице на Си для Unix систем. Прекрасно взаимодействует с приложениями на основе WinSock (Win32 платформы). Но все же работа сокетов на Unix и Win32 платформах требует аккуратности и внимательности. Отличия-то имеются!


// Содержит прототипы функций библиотеки Socket API
#include <sys/socket.h>
// Содержит объявления стандартных системных типов данных
#include <sys/types.h>
// Содержит объявления дополнительных типов данных
#include <resolv.h>
// Для вызова стандартных низкоуровневых функций ввода-вывода для приема и передачи данных
#include <unistd.h>
// Для работы со строками
#include <stdio.h>


// Номер порта для соединения с сервером
#define PORT_TIME 80
// Размер буфера
#define MAXBUF 1024

void main () {

    // Объявляем дескриптор сокета sd
    int sd;
    // Адрес сервера
    char *host = "192.168.0.10";
    // Создаем буфер
    char buffer[MAXBUF];
    // Отправляемое на сервер сообщение
    char *sendbuf = "Hello mister tester. I am glad to see you.";
   
    // Создание структуры для функции connect()
    struct sockaddr_in dest;

    // Системный вызов сокета. По-сути инициализация канала связи
    // domain = PF_INET, type = SOCK_STREAM, protocol = 0
    // int socket(int domain, int type, int protocol);

    // Вызов протокола TCP
    // В sd помещается дескриптор сокета
    sd = socket(PF_INET, SOCK_STREAM, 0);

    // Обнуляем структуру
    bzero(&dest, sizeof(dest));
    // Выбираем протокол
    dest.sin_family = AF_INET;
    // Функции htons() и inet_aton() выполняют преобразования типов данных
    // Выбираем порт
    dest.sin_port = htons(PORT_TIME);
    // Задаем адрес
    inet_aton(host, &dest.sin_addr);

    // Подключаемся к серверу
    if (connect(sd, &dest, sizeof(dest)) != 0) {
        printf("connect() filed");
    }
    // Заносим сообщение в буфер
    //sprintf(buffer, "%s\n", sendbuf);
    // Отправляем на сервер данные в буфере
    //send(sd, buffer, strlen(bufer), 0);
    send(sd, sendbuf, strlen(sendbuf), 0);
    // Обнуляем буфер; для приема ответа от сервера
    bzero(buffer, MAXBUF);
    // Принимаем ответ сервера
    recv(sd, buffer, MAXBUF-1, 0);
    // Выводим на консоль содержимое ответа
    printf("%s", buffer);
    // Закрываем сокет
    close(sd);
}

Good luck, friends :)

C/C++. Named pipe. Именованный канал

Именованный канал (named pipe) применяется как один из методов межпроцессорного взаимодействия: один процесс создает параллельный процесс. Которые имеют возможность взаимодействовать между собой. В отличие от традиционного канала, именованный канал существует в системе и после завершения основного процесса. Поэтому он должен быть «отсоединён» или удалён когда уже не используется.

В Unix системах инициализируется функцией popen() и закрывается - pclose(). На платформе Win32 - _popen(), _pclose().

Если рассмотреть вариант для Win32 систем, то полный синтаксис выглядит следующим образом (ссылка на msdn).

FILE *_popen(
   const char *command,
   const char *mode 
); 

*command - собственно, команда на выполнение, например "C://script.exe";

*mode - режим получаемого потока (параллельного процесса). Четыре режима (в

упрощенном виде): r - режим чтения, w - режим записи, b - бинарный режим,

t - текстовый режим.

int _pclose(
   FILE *stream 
); 

Далее приведен пример работы с именованным каналом. 

#include <stdio.h>
#include <stdlib.h>

int main(void)
{

   char   Buffer[128];
   FILE   *pPipe;

        /* Run script.exe so that it writes its output to a pipe. Open this
         * pipe with read binary attribute.
         */

   if((pPipe = _popen("C://script.exe", "rb")) == NULL)
      exit(1);

        /* Read pipe until end of file. */

   while(!feof(pPipe))
   {
      if(fgets(Buffer, 128, pPipe) != NULL)
         printf(Buffer);
   }

        /* Close pipe and print return value of pPipe. */

   printf("\nProcess returned %d\n", _pclose(pPipe));
}  

Всем удачи!