CN lab
server.c #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <arpa/inet.h> #include <sys/socket.h> #define PORT 8080 #define MAX_CLIENTS 10 int main() { int server_fd, new_socket, valread; struct sockaddr_in address; int addrlen = sizeof(address); char buffer[1024] = {0}; char *welcome_message = "Welcome to the chat!\n"; char reply_message[1024]; // Create socket file descriptor if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) { perror("socket failed"); exit(EXIT_FAILURE); } // Set socket options int opt = 1; 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); // Bind the socket to localhost port 8080 if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) { perror("bind failed"); exit(EXIT_FAILURE); } // Listen for incoming connections if (listen(server_fd, MAX_CLIENTS) < 0) { perror("listen"); exit(EXIT_FAILURE); } // Accept incoming connections while ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen))) { printf("New client connected.\n"); // Send welcome message to client send(new_socket, welcome_message, strlen(welcome_message), 0); // Handle messages from client while ((valread = read(new_socket, buffer, 1024)) > 0) { printf("Client: %s\n", buffer); // Get reply from server printf("Reply: "); fgets(reply_message, 1024, stdin); // Send reply to client send(new_socket, reply_message, strlen(reply_message), 0); printf("Sent: %s\n", reply_message); // Print the sent message memset(buffer, 0, sizeof(buffer)); } } return 0; } client.c #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <arpa/inet.h> #include <sys/socket.h> #define PORT 8080 int main() { int sock = 0, valread; struct sockaddr_in serv_addr; char buffer[1024] = {0}; char message[1024]; // Create socket file descriptor if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0) { printf("\n Socket creation error \n"); return -1; } serv_addr.sin_family = AF_INET; serv_addr.sin_port = htons(PORT); // Convert IPv4 and IPv6 addresses from text to binary form if (inet_pton(AF_INET, "127.0.0.1", &serv_addr.sin_addr) <= 0) { printf("\nInvalid address/ Address not supported \n"); return -1; } // Connect to server if (connect(sock, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) { printf("\nConnection Failed \n"); return -1; } // Receive welcome message from server valread = read(sock, buffer, 1024); printf("%s", buffer); // Handle messages to and from the server while (1) { // Get user input printf("Enter message: "); fgets(message, 1024, stdin); // Send message to server send(sock, message, strlen(message), 0); // Receive message from server valread = read(sock, buffer, 1024); printf("Server: %s\n", buffer); memset(buffer, 0, sizeof(buffer)); } return 0; }
Leave a Comment