1

これは、私が書いたチャット クライアント サーバー プログラムのサーバー部分です。スレッドのプールを作成し、サーバーは接続されたクライアントをスレッドに関連付ける必要があります。スレッド関数 gestisci() は、クライアントからコマンドを受信し、クライアント 1 からクライアント 2 にメッセージを送信します。しかし、一度実行すると、端末には何も表示されません。誰かが私を助けることができますか?

#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>

#include <sys/types.h>
#include <sys/socket.h>
#include <sys/stat.h>
#include<sys/wait.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<pthread.h>

#define BACKLOG_SIZE 5
#define SA struct sockaddr

void* gestisci_richiesta(void*dati)

int main(int argc, char* argv[]) {

    printf("in main function\n");
    struct sockaddr_in srv_addr, cl_addr;
    int ret, sock, cn_sk, porta, t;
    struct argomenti{
        int sock_cl,stato;
        struct sockaddr_in cl_addr;
        int index;}
    struct argomenti mess[BACKLOG_SIZE];
    int arg_cont[BACKLOG_SIZE];
    socklen_t len;
    int t_free[BACKLOG_SIZE];
    pthread_t tid[BACKLOG_SIZE];

    if (argc < 2)
        printf("errore:inserire numero porta\n");

    porta = atoi(argv[1]);
    printf(" %d\n", porta);

    sock = socket(PF_INET, SOCK_STREAM, 0);
    if (sock == -1) {
        printf("server: impossibile creare un nuovo socket.\n");
        return 0;
    }

    memset(&srv_addr, 0, sizeof(srv_addr));
    srv_addr.sin_family = AF_INET;
    srv_addr.sin_addr.s_addr = htonl(INADDR_ANY );/* il server si mette in ascolto suqualsiasi delle sueinerfacce di rete*/
    srv_addr.sin_port = htons(porta);

    ret = bind(sock, (SA*) &srv_addr, sizeof(srv_addr));
    if (ret == -1) {
        printf("server : impossibile eseguire il bind sul socket.\n");
        return 0;
    }
    printf("bind con successo\n");

    listen(sock, BACKLOG_SIZE);
    for (t = 0; t < BACKLOG_SIZE; t++) {
        t_free[t] = 0;
        client[t] = 0;
    }

              t= 0;
    while (1) {

        while (t_free[t] != 0)
            t = (t + 1) % BACKLOG_SIZE;
        t_free[t] = 1;
        len = (socklen_t) sizeof(mess[t].cl_addr);
        cn_sk = accept(sock, (SA*) &mess[t].cl_addr, &len);
        mess[t].sock_cl = cn_sk;
        mess[t].index = t;
        printf("client:%d connesso\n", t);
        if (cn_sk == -1) {
            printf("SERVER: errore in attesa di connessione\n");
            return 0;
        }
        if (pthread_create(&tid[t], 0, gestisci_richiesta, (void*) &mess[t])) {
            printf("server:impossibile avviare un thread dal pool\n");
            return 0;
        }
    }
}
4

2 に答える 2

0

これらの printfs のいくつかで \n が欠落しているため、すぐに印刷するのではなく、バッファーに入れられます。

他にも問題があります。socket() を呼び出すエラーメッセージは誤解を招くものです。指定されたポートはまだ使用されていません。それは bind() で起こります。クライアントの数がバックログのサイズと等しいと仮定する理由はありません。sockaddr_in のサイズは常に同じです。毎回再計算する必要はありません。

于 2012-08-22T23:55:11.310 に答える
0

t = 0;前に移動する必要がありますwhile(1)

于 2012-08-23T00:29:52.050 に答える