Kanal.c 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132
  1. #include <Windows.h>
  2. #include <malloc.h>
  3. #include <stdio.h>
  4. #include <locale.h>
  5. #define SIWPO_SIZE 140
  6. #define MAX_BUF_SIZE 1024
  7. int main()
  8. {
  9. system("chcp 1251");
  10. //HANDLE hNamePipie;// дескриптор канала
  11. //LPSTR lipzPipe = L"\\\\.\\pipe\\MyPipe";//имя канала (путь к каналу) . указатель на локальный хост
  12. //DWORD vis_size = SIWPO_SIZE;
  13. //LPWSTR buffer = (CHAR*)calloc(vis_size, sizeof(CHAR));// сюда считаем файлы(данные)
  14. //char messege[SIWPO_SIZE];
  15. //BOOL Conected;
  16. //DWORD actual_reader;
  17. //BOOL SecceRead;
  18. //
  19. // while (TRUE)
  20. // {
  21. // hNamePipie = CreateNamedPipe(lipzPipe,PIPE_ACCESS_DUPLEX,PIPE_TYPE_MESSAGE|PIPE_READMODE_MESSAGE|PIPE_WAIT,PIPE_UNLIMITED_INSTANCES, SIWPO_SIZE, SIWPO_SIZE,INFINITE,NULL);
  22. // //создание канала (имя канала(путь), режим доступа к каналу сим или дуп, что может делать канал( режим работы), количество соединений,обьем буфера,время ожидания,безопасность)
  23. // Conected = ConnectNamedPipe(hNamePipie, NULL);// определяет клиент к серверу или нет (соединение клиента с каналом)
  24. // if (Conected)//
  25. // {
  26. // printf("\nКлиент успешно подключился \n");
  27. // SecceRead = ReadFile(hNamePipie, buffer, vis_size, &actual_reader, NULL);//куда прочитал, сколько прочитал, сколько с самого начала считается, читает с начала
  28. // if (SecceRead)
  29. // {
  30. // printf("\nКлиент пишет..\n");
  31. // printf(buffer);
  32. // printf("\n");
  33. //
  34. // printf("\nВведите сообщение для клиента....\n");
  35. // gets(messege);
  36. // buffer = &messege;
  37. // WriteFile(hNamePipie, buffer, vis_size, &actual_reader, NULL);
  38. //
  39. //
  40. // }
  41. // else
  42. // {
  43. // printf("\nКлиент успешно пошел на \n");
  44. // }
  45. //
  46. // CloseHandle(hNamePipie);
  47. // }
  48. // }
  49. //
  50. //
  51. HANDLE hNamePipie;// дескриптор канала
  52. LPSTR lipzPipe = L"\\\\.\\pipe\\MyPipe";
  53. char read_buf[MAX_BUF_SIZE];
  54. char write_buf[MAX_BUF_SIZE];
  55. while (1)
  56. {
  57. // Открытие именованного канала для чтения
  58. hNamePipie = CreateNamedPipe(lipzPipe, PIPE_ACCESS_DUPLEX, PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, SIWPO_SIZE, SIWPO_SIZE, INFINITE, NULL);
  59. // Чтение данных от клиента
  60. read(hNamePipie, read_buf, sizeof(read_buf));
  61. // Преобразование строки в число
  62. int number = atoi(read_buf);
  63. // Проверка корректности ввода
  64. if (number == 0 && strcmp(read_buf, "0") != 0)
  65. {
  66. // Формирование сообщения об ошибке
  67. snprintf(write_buf, sizeof(write_buf), "Некорректный ввод: '%s'", read_buf);
  68. }
  69. else
  70. {
  71. // Возведение числа в квадрат
  72. int square = number * number;
  73. // Преобразование числа в строку
  74. snprintf(write_buf, sizeof(write_buf), "%d", square);
  75. }
  76. // Закрытие именованного канала для чтения
  77. close(hNamePipie);
  78. // Открытие именованного канала для записи
  79. hNamePipie = CreateNamedPipe(lipzPipe, PIPE_ACCESS_DUPLEX, PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, SIWPO_SIZE, SIWPO_SIZE, INFINITE, NULL);
  80. // Запись результата в канал
  81. write(hNamePipie, write_buf, strlen(write_buf) + 1);
  82. // Закрытие именованного канала для записи
  83. close(hNamePipie);
  84. }
  85. return 0;
  86. }