0

クライアントからメッセージを取得し、辞書 (ファイルにある辞書) にある単語で応答するサーバーを作成しました。例えば:

Client wrote: cat
Server got: cat, Server wrote: miauuu! (and client can see the massege 
from server in his window)

私の dict.txt ファイルは次のようになります。

cat
miauuu!
dog
raw,raw!
etc...

サーバーがクライアントからメッセージを取得するため、コードに問題がありますが、クライアントにメッセージを送信するにはまだ問題があります...(クライアントウィンドウでサーバーからのメッセージが表示されません)。クライアントとして、telnet を使用します。何か案は?

つまり、サーバー: ./server 9999 および telnet: telnet 127.0.0.1 9999 を実行し、サーバーにメッセージを送信できます (サーバーはそれらを見ることができます) が、telnet 側ではサーバーからのメッセージを見ることができません (サーバーも空の文字列を送信します (または何も送信しません。よくわかりません))

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <netdb.h>
#include <pthread.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <map>
#include <string>
#include <iostream>
#include <fstream>
using namespace std;

map <string, string> dict;

void* clients_service(void * arg)
{
    int client_fd = *((int*)&arg), buffsize = 1024, bytes_num = 0;
    char buffer[1024];
    char word[1024];

    while(1)
        {
            if ((bytes_num = read(client_fd, buffer, buffsize)) == -1)
            {
                perror("read error");
                exit(1);
            }
            else if (bytes_num == 0)
            {
                fprintf(stdout, "connection closed.\n");
                break;
            }

            buffer[bytes_num] = '\0';
            fprintf(stdout, "Got: %s", buffer);
            string from_client(buffer);
            string to_client = dict[from_client];

            char buff[1024];

            strncpy(buff, to_client.c_str(), strlen(buff));
            buff[strlen(buff) - 1] = '\0';

            if ((write(client_fd, buff, strlen(buff))) == -1)
            {
                fprintf(stderr, "write error\n");
                close(client_fd);
                break;
            }

            fprintf(stdout, "I wrote: %s", buff);

        }
        close(client_fd);
}

void loadDictionary(map <string, string> &dict)
{
    dict.clear();
    ifstream file("dict.txt");
    string s1, s2;

    if(file.is_open())
    {
        while(file.good())
        {
            getline(file, s1);
            getline(file, s2);
            dict.insert(pair<string, string>(s1, s2));
        }
    }

    file.close();
}

int main(int argc, char **argv)
{
    int server_soc_fd, port, buffsize = 1024;
    char buffer[buffsize];
    struct sockaddr_in addr;
    socklen_t addrlen = sizeof(addr);
    loadDictionary(dict);

    if (argc < 2)
    {
        fprintf(stderr, "Use : ./server {port number}\n");
        exit(1);
    }

    port = atoi(argv[1]);
    addr.sin_family = AF_INET;
    addr.sin_port = htons(port);
    addr.sin_addr.s_addr = INADDR_ANY;
    server_soc_fd = socket(AF_INET, SOCK_STREAM, 0);

    if(server_soc_fd < 0)
    {
        perror("socket");
        exit(1);
    }

    if(bind(server_soc_fd,(struct sockaddr *)&addr, addrlen) < 0)
    {
        perror("bind");
        exit(1);
    }

    if(listen(server_soc_fd, 10) < 0)
    {
        perror("listen");
        exit(1);
    }

    fprintf(stdout, "\nWorking...\n\n");

    while(true)
    {
        int client_soc_fd = accept(server_soc_fd, NULL, NULL);
        pthread_t thread;
        pthread_create(&thread, NULL, clients_service, (void*)client_soc_fd);
    }

    return 0;
}
4

1 に答える 1

1

これ:

char buff[1024];

strncpy(buff, to_client.c_str(), strlen(buff));
buff[strlen(buff) - 1] = '\0';

満たされませんbuff

char *strncpy(char *dest, const char *src, size_t n);

からにnバイトをコピーします。srcdest

したがって、次のことを行うことをお勧めします。

const char * cstr = to_client.c_str();
size_t len = strlen(cstr);
strncpy(buff, cstr, max(len, sizeof(buff)-1));
buff[len] = 0;

またはさらに良いこと:

const char * cstr = to_client.c_str();
size_t len = strlen(cstr);
if (!len)
  continue;

if ((write(client_fd, cstr, len) == -1)
{
  ...

write()また、一度にすべてのデータを書き込むことに頼るべきではありません。

したがって、次のように拡張できます。

...
const char * cstr = to_client.c_str();
size_t len = strlen(cstr);

size_t lenWrittenTotal = 0;
while (lenWrittenTotal < len);
{
  ssize_t lenWritten = write(client_fd, cstr + lenWrittenTotal , len - lenWrittenTotal);

  if (lenWritten < 0)
  {
    perror("write");
    break;
  } 
  else if (lenWritten > 0)
  {
    lenWrittenTotal += lenWritten;
  }
  else
  {
    ... 
    break;
  }
};
...
于 2012-11-11T14:12:40.543 に答える