Задача состоит в том, чтобы написать простой сетевой чат. Нет принципиальной разницы в языке, но я решил писать на Си.
Сервер должен быть способен обрабатывать несколько пользователей одновременно, а пользователи в свою очередь должны иметь возможность запрашивать список всех активных пользователей и писать им сообщения. Если пользователь выходит из сети, то соответственно отключается от сервера и вычеркивается из списка активных пользователей.
Когда я добавил функции регистрации и выдачи списка активных пользователей, столкнулся с проблемой, что обращаясь к серверу в только что созданных потоках не вызывает проблем, но если обратиться из ранее созданного потока, то сервер зависает.
Подумал что дело в одновременном использовании памяти, хотя это было маловероятно, ведь вводил все я один с одной машины, но на всякий случай добавил мьютексы, не помогло.
Также подумал что дело может быть в засоренном буфере ввода, но функция его очистки в некоторых местах либо не делает ничего, либо делает только хуже.
Моя последняя догадка только в том, что моя реализация просто не подходит для pthread потоков, и нужно все переписывать с использованием общей памяти и fork(), но хотелось бы этого избежать.
Вот код
Cервер:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <unistd.h>
#include <pthread.h>
#define PORT 8080
#define BUFFER_SIZE 1024
#define MAX_CONNECTIONS 5
#define REGISTRATION '1'
#define CHECKINFO '2'
#define SENDMESSAGE '3'
#define EXIT '4'
struct Node {
char name[30];
struct Node* next;
};
struct Node* createNode(char* name) {
struct Node* newNode = (struct Node*)malloc(sizeof(struct Node));
for(int i = 0; i < 30; i++)
{
newNode->name[i] = name[i];
}
newNode->next = NULL;
return newNode;
}
void CleanStdin()
{
char c;
while ((c = getchar()) != '\n' && c != EOF) {}
}
void pushBack(struct Node** headRef, char* name) {
struct Node* newNode = createNode(name);
if (*headRef == NULL) {
*headRef = newNode;
return;
}
struct Node* temp = *headRef;
while (temp->next != NULL) {
temp = temp->next;
}
temp->next = newNode;
}
void Delete(struct Node** headRef, char* name)
{
struct Node* temp = *headRef;
struct Node* prev = temp;
if (strcmp(temp->name, name) == 0)
{
*headRef = NULL;
return;
}
while (temp != NULL)
{
if (strcmp(temp->name, name) == 0)
{
prev->next = temp->next;
free(temp);
return;
}
prev = temp;
temp = temp->next;
}
}
int Find(struct Node** headRef, char* name)
{
struct Node* temp = *headRef;
while (temp != NULL)
{
if (strcmp(temp->name, name) == 0)
{
return 1;
}
temp = temp->next;
}
return 0;
}
void PrintUsers(struct Node** headRef, int sock, int usersVal)
{
struct Node* temp = *headRef;
for (int i = 0; i < usersVal; i++)
{
send(sock, temp->name, 30, 0);
temp = temp->next;
}
}
pthread_t thread_id;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
struct Node* head = NULL;
int server_fd, new_socket;
struct sockaddr_in address;
int opt = 1;
int addrlen = sizeof(address);
char buffer[BUFFER_SIZE];
int usersVal = 0;
void* mainFunc()
{
char name[30];
// Чтение сообщения от клиента
while(1)
{
//CleanStdin();
memset(buffer, (char)0, BUFFER_SIZE);
char operation;
if ( operation == REGISTRATION)
{
read(new_socket, name, 30);
int RegCode;
if (Find(&head, name) == 1)
{
printf("User already registered: %s", name);
RegCode = 1;
}
else
{
printf("User successfully registered: %s", name);
pushBack(&head, name);
pthread_mutex_lock(&mutex);
usersVal++;
pthread_mutex_unlock(&mutex);
RegCode = 0;
}
send(new_socket, &RegCode, 4, 0);
}
else if (operation == CHECKINFO)
{
pthread_mutex_lock(&mutex);
printf("\nUserval = %d\n", usersVal);
send(new_socket, &usersVal, 4, 0);
pthread_mutex_unlock(&mutex);
//PrintUsers(&head, new_socket, usersVal);
}
else if (operation == EXIT)
{
close(new_socket);
printf("\nExited!\n");
//Delete(&head, name);
pthread_mutex_lock(&mutex);
usersVal--;
pthread_mutex_unlock(&mutex);
CleanStdin();
break;
}
read(new_socket, &operation, 1);
}
return NULL;
}
int main(int argc, char const *argv[]) {
// Создание сокета
if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) {
perror("socket failed");
exit(EXIT_FAILURE);
}
// Присваивание опции сокету (можно повторно использовать адрес)
if (setsockopt(server_fd, SOL_SOCKET, SO_REUSEADDR | SO_REUSEPORT, &opt, sizeof(opt))) {
perror("setsockopt");
exit(EXIT_FAILURE);
}
address.sin_family = AF_INET;
address.sin_addr.s_addr = INADDR_ANY;
address.sin_port = htons( PORT );
// Привязка сокета к адресу и порту
if (bind(server_fd, (struct sockaddr *)&address, sizeof(address))<0) {
perror("bind failed");
exit(EXIT_FAILURE);
}
// Ожидание входящих соединений
if (listen(server_fd, MAX_CONNECTIONS) < 0) {
perror("listen");
exit(EXIT_FAILURE);
}
// Принятие входящего соединения
while(1)
{
if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen))<0)
{
perror("accept");
exit(EXIT_FAILURE);
}
printf("\nConnected!\n");
pthread_create(&thread_id, NULL, mainFunc, NULL);
}
return 0;
}
Клиент:
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#define SERVER_ADDRESS "127.0.0.1"
#define SERVER_PORT 8080
#define BUFFER_SIZE 1024
#define REGISTRATION '1'
#define CHECKINFO '2'
#define SENDMESSAGE '3'
#define EXIT '4'
int Socket(int domain, int type, int protocol)
{
int sock = socket(domain, type, protocol);
if (sock < 0) {
perror("Failed to create socket");
exit(EXIT_FAILURE);
}
return sock;
}
void Inet_pton(int af, const char *src, void *dst)
{
if (inet_pton(af, src, dst) <= 0) {
perror("Invalid server address");
exit(EXIT_FAILURE);
}
}
void Connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen)
{
if (connect(sockfd, addr, addrlen) < 0) {
perror("Failed to connect to server");
exit(EXIT_FAILURE);
}
}
void Send(int sockfd, const void *buf, size_t len, int flags)
{
if (send(sockfd, buf, len, flags) < 0)
{
perror("Failed to send message to server");
exit(EXIT_FAILURE);
}
}
void Recv(int sockfd, void *buf, size_t len, int flags)
{
if (recv(sockfd, buf, len, flags) < 0) {
perror("Failed to receive message from server");
exit(EXIT_FAILURE);
}
}
// Создание сокета и подключение к серверу
int Conn()
{
int sock = Socket(AF_INET, SOCK_STREAM, 0);
struct sockaddr_in server_address;
server_address.sin_family = AF_INET;
server_address.sin_port = htons(SERVER_PORT);
Inet_pton(AF_INET, SERVER_ADDRESS, &server_address.sin_addr);
Connect(sock, (struct sockaddr*) &server_address, sizeof(server_address));
return sock;
}
void CleanStdin()
{
char c;
while ((c = getchar()) != '\n' && c != EOF) {}
}
int main() {
char buffer[BUFFER_SIZE];
char symb, operation;
int sock = Conn();
// Первоначальная регистрация
operation = REGISTRATION;
Send(sock, &operation, 1, 0);
printf("\nEnter Name: ");
fgets(buffer, 30, stdin);
Send(sock, buffer, 30, 0);
int RegCode;
Recv(sock, &RegCode, 4, 0);
if (RegCode == 1)
{
printf("You was registered before");
}
else if (RegCode == 0)
{
printf("You were successfully registered");
}
while(1)
{
CleanStdin();
memset(buffer, (char)0, BUFFER_SIZE);
printf("\n1. Get users info");
printf("\n3. Exit\n");
symb = getchar();
switch (symb)
{
// Регистрация пользователя
case '1':
{
operation = CHECKINFO;
Send(sock, &operation, 1, 0);
int usersVal;
Recv(sock, &usersVal, 4, 0);
printf("\nAmount of users = %d\n", usersVal);
/*for(int i = 0; i < usersVal; i++)
{
char name[30];
Recv(sock, name, 30, 0);
printf("\nUser: %s\n", name);
}*/
break;
}
case '3':
{
operation = EXIT;
printf("Exiting...\n");
Send(sock, &operation, 1, 0);
exit(0);
}
}
}
return 0;
}
Не судите строго, сам знаю как все это выглядит, писал весь день без остановки, колхозил как мог, лишь бы только закончить.
Я комментировал строки, которые как мне казалось могут содержать ошибку, но разницы не было. Ошибка возникает если сделать по порядку следующее:
- Запустить сервер
- Запустить приложение клиента в другом окне терминала (работаю в Ubuntu)
- Ввести имя
- Запустить новое приложение клиента в третьем окне терминала не закрывая старого
- Ввести имя и выйти
- Перейти ко второму окну и попытаться получить список активных пользователей (сейчас там заглушка просто показывающая количество активных пользователей)
Есть ли возможность это исправить, или переделать уже имеющееся чтобы работало? Буду благодарен за любые советы. Ниже приведу более подробное описание задачи.
Необходимо реализовать – «ЧАТ».
Необходимо реализовать с использованием сетевых сокетов две программы: Клиент и Сервер. Сервер должен быть один. Клиентов может быть много.
Сервер.
После запуска работает в бесконечном цикле слушая закрепленный за ним сокет, пока не поступит команда на его завершения.
К серверу через сокет, могут поступать следующие виды запросов от клиента:
Запрос на регистрацию (сервер должен вести список зарегистрированных клиентов). При поступлении данного запроса проверяется данный список, если клиент там не зарегистрирован, то происходит его регистрация. Клиенту отправляется ответ с подтверждением регистрации или сообщением о том, что он уже зарегистрирован.
Запрос на получение списка зарегистрированных клиентов. В ответ сервер отправляет Имена клиентов, зарегистрированных в данный момент.
Запрос на передачу сообщения клиенту. (в запросе указывается имя клиента получателя и текст сообщения). Если клиент получатель не зарегистрирован в чате, то отправителю сообщения отправляется об этом информация, иначе сообщение пересылается клиенту получателю.
Запрос на отключение от чата. В этом случае клиент удаляется из чата.
Клиент.
После запуска запрашивает параметры сервера (адрес и порт), а также имя клиента и пытается подключиться к серверу – отправляет запрос на регистрацию. Если подключение невозможно (не получен ответ), то завершает свою работу.
Иначе либо ждет команду от пользователя, либо сообщение от сервера.
При поступлении сообщения, выводит имя отправителя и сам текст сообщения.
Пользователь может ввести следующие команды:
Получить список зарегистрированных в чате. В этом случае клиент запрашивает этот список на сервере и выводит его на экране.
Отправить сообщение. Указывается имя клиента получателя и текст сообщения.
Команда на завершение работы. Отправляется соответствующий запрос на сервер и программа завершает свою работу.
При выполнении лабораторной работы обязательно необходимо для взаимодействия использовать сокеты операционной системы.