1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85
| #include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <pthread.h>
#include <iostream>
#include <stdio.h>
#include "need.h"
using namespace std;
void* Thread_Client(void *);
void* Thread_Encrpt(void *);
void* Thread_Check(void *);
int sockd;
int main(int argc, char *argv[])
{
sockaddr_in sin;
int count;
if((sockd = socket(AF_INET, SOCK_STREAM, 0)) == SOCK_ERROR)
{
cerr << "Creation socket error !\n";
return 0;
}
sin.sin_family = AF_INET;
sin.sin_port = htons(DEFAULT_PORT);
sin.sin_addr.s_addr = inet_addr("127.0.0.1");
if((bind(sockd, (sockaddr *) &sin, sizeof(sin)) == SOCK_ERROR))
{
cerr << "Bind socket error !\n";perror("");
return 0;
}
listen(sockd, MAX_CLIENT);
for(count = 0 ; count < MAX_CLIENT ; count++)
{
int len = sizeof(Cl[count].csin);
// system("clear");
cout << "Number of clients: " << count << "\n";
if((Cl[count].sockd = accept(sockd, (sockaddr *) &Cl[count].csin, (socklen_t *) &len)) == SOCK_ERROR)
{
cerr << "Accept() error !\n";
return 0;
}
pthread_create(&Thread_id[count], 0, &Thread_Client, (void *) &count);
send(Cl[count].sockd, WELCOME, strlen(WELCOME), 0);
send(Cl[count].sockd, LOGIN, strlen(LOGIN), 0);
}
system("pause");
return 0;
}
void* Thread_Client(void *vParam)
{
int *nb = (int *) vParam;
char buffer[MAX_RECV];
*nb--;
Cl[*nb].state = true;
recv(sockd, buffer, sizeof(buffer), 0);
cout << buffer << endl;
}
void* Thread_Encrypt(void *vParam)
{
}
void* Thread_Check(void *vParam)
{
} |
Partager