Implementation of a TCP server in multithreaded C, C + + The initial part of the program must include the necessary the use of socket:
# include # include # include
# include
int main (int argc, char * argv []) {
int sockfd;
newsockfd int = 0;
; struct sockaddr_in serv_addr, cli_addr;
you create the socket for the server
sockfd = socket (AF_INET, SOCK_STREAM, 0);
if ( sockfd \u0026lt;0) {
perror ("FATAL: Unable to open TCP listener");
exit (1);}
you bind on ' address / port wanted
bzero ((char *) & serv_addr, sizeof (serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr . sin_addr.s_addr = INADDR_ANY;
serv_addr.sin_port = htons (0x4bfc)
if (bind (sockfd, (struct sockaddr *) & serv_addr, sizeof (serv_addr)) \u0026lt;0) {
perror ("FATAL: Unable to bind the TCP listener ");
exit (1);}
and listens to
listen (sockfd, 5);
at this point for each new incoming connection is accepted create a specific thread that runs it. E 'must wait to be sure that the new thread has taken over the value of the socket to use for communication.
while (true) {socklen_t
clilen = sizeof (cli_addr)
newsockfd = accept (sockfd, (struct sockaddr *) & cli_addr, & clilen) if
(Newsockfd \u0026lt;0) {perror
("New connection created");
;} else {
pthread_t pth;
; pthread_create (& pth, NULL, InitiateThreadTCP, (void *)newsockfd);
pthread_detach(pTh);
int maxsleep = 1000;
while (newsockfd > 0 && maxsleep > 0) {
usleep (1000);
maxsleep -;
;}}
}
Gestin the function of communication is the Next, remember to define the beginning del file prima del main.
void * InitiateThreadTCP( void *p )
{
int sck = &(int *)p;
char rbuffer[1000];
char sbuffer[1128];
int n = read(sck, rbuffer, 1022);
if (n >= 0) {
rbuffer[n] = 0;
sprintf (sbuffer, "Received message:% s", rbuffer)
write (SCK sbuffer, strlen (sbuffer));}
close (SCK);
pthread_exit (NULL);}
Here is the complete source
# include # include # include
# includes
InitiateThreadTCP void * (void * p)
SCK = & {int (int *) p;
rbuffer char [1000];
sbuffer char [1128];
int n = read (SCK rbuffer, 1022);
if (n> = 0) {
rbuffer [n] = 0;
sprintf (sbuffer, "Received messaggio: %s ", rbuffer);
write(sck, sbuffer, strlen(sbuffer));
}
close(sck);
pthread_exit( NULL );
}
int main(int argc, char *argv[])
{
int sockfd;
int newsockfd = 0;
struct sockaddr_in serv_addr, cli_addr;
sockfd = socket(AF_INET, SOCK_STREAM, 0);
if ( sockfd < 0 ) {
perror("FATAL: Impossibile aprire il listener TCP");
exit(1);
}
bzero((char *) &serv_addr, sizeof(serv_addr));
serv_addr.sin_family = AF_INET;
serv_addr.sin_addr.s_addr = INADDR_ANY;
serv_addr.sin_port = htons(0x4bfc);
if ( bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0 ) {
perror("FATAL: Impossibile effettuare il bind del listener TCP");
exit(1);
}
listen(sockfd,5);
while( true ) {
socklen_t clilen = sizeof(cli_addr);
newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen);
if (newsockfd \u0026lt;0) {perror
("New connection created");
} else {pthread_t pth;
pthread_create(&pTh, NULL, InitiateThreadTCP, (void *)newsockfd);
pthread_detach(pTh);
int maxsleep = 1000;
while (newsockfd > 0 && maxsleep > 0) {
usleep(1000);
maxsleep--;
}
}
}
exit(0);
}
