私は UNIX ネットワーク プログラミングを学ぼうとしていたので、クライアントがメッセージを送信し、サーバーが大文字に変換されたメッセージを返すクライアント/サーバー プログラムを作成しようとしました。
サーバーを実行し、クライアントを使用して自分のマシンに接続し、いくつかのテスト文字列を送信すると、以前に入力したものが画面に書き込まれるまで問題なく動作します。
バッファと関係があると思われます。サーバーを起動した後に実行されるサンプルは次のとおりです。
can@ubuntu:~$ cd デスクトップ
can@ubuntu:~/Desktop$ ./tcpuppcli 127.0.0.1
エコーする文字列を入力してください: test
エコー応答: テスト
エコーする文字列を入力してください: string2
エコー応答: STRING2
エコーする文字列を入力してください: string3
エコー応答: STRING3
エコーする文字列を入力してください: aaaaaaaaafsfagd
エコー応答: AAAAAAAAAFSFAGD
エコーする文字列を入力してください: gdsgsg
エコー応答: GDSGSG
AAFSFAGD ----------->!これは、前の入力からの文字を含む奇妙な行です!
エコーする文字列を入力してください: ^C
can@ubuntu:~/Desktop$
サーバーとクライアントのコードは次のとおりです。
// methods with prefix w_ are just error checking wrappers from UNP by Stevens
// server
#include "socketwrap.h" // headers necessary and constants like MAXLINE
#include <ctype.h>
void sigchld_handler( int sig);
void str_upper( int connfd);
void toUpperCase( char buffer[], int length);
int main( int argc, char** argv)
{
int listenfd;
int connfd;
pid_t childpid;
struct sockaddr_in serverAddress;
struct sockaddr_in clientAddress;
socklen_t length;
struct sigaction sa;
// Create the socket
listenfd = w_socket( AF_INET, SOCK_STREAM, 0);
// Clear the serverAddress structure
bzero( &serverAddress, sizeof( serverAddress));
// Set up the serverAddress structure
serverAddress.sin_family = AF_INET;
serverAddress.sin_addr.s_addr = htonl( INADDR_ANY);
serverAddress.sin_port = htons( 11979);
// Bind the socket to a well-defined port
w_bind( listenfd, (struct sockaddr*) &serverAddress, sizeof( serverAddress));
// Start listening for connections
w_listen( listenfd, BACKLOG);
// Handle any zombie children by using a signal handler
sa.sa_handler = sigchld_handler;
sigemptyset( &sa.sa_mask);
sa.sa_flags = SA_RESTART;
if( sigaction( SIGCHLD, &sa, NULL) == -1)
{
perror( "signal error");
exit( 1);
}
printf( "Waiting for connections...\n");
while( 1)
{
length = sizeof( clientAddress);
connfd = w_accept( listenfd, ( struct sockaddr*) &clientAddress, &length);
if( connfd < 0)
{
if( errno == EINTR)
{
continue; // back to while
}
else
{
perror( "accept error");
exit( 1);
}
}
printf( "Obtained connection...\n");
childpid = fork();
if ( childpid == 0) /* child process */
{
w_close( listenfd); /* close listening socket */
str_upper( connfd); // process the request
exit( 0);
}
w_close( connfd); /* parent closes connected socket */
}
}
void sigchld_handler( int sig)
{
while( waitpid( -1, NULL, WNOHANG) > 0);
}
void str_upper( int connfd)
{
char buffer[MAXLINE];
while( read( connfd, buffer, MAXLINE - 1) > 0)
{
toUpperCase( buffer, strlen( buffer));
write( connfd, buffer, strlen( buffer));
}
}
void toUpperCase( char buffer[], int length)
{
int i;
for( i = 0; i < length - 1; i++)
{
buffer[i] = toupper( buffer[i]);
}
}
// client
#include "socketwrap.h"
void str_cli( int connfd);
int main( int argc, char** argv)
{
int sockfd;
struct sockaddr_in serverAddress;
if( argc != 2)
{
printf( "Invalid argument count\n");
printf( "Correct usage: tcpcli4 <IPaddress>\n");
exit( 1);
}
sockfd = w_socket( AF_INET, SOCK_STREAM, 0);
bzero( &serverAddress, sizeof( serverAddress));
serverAddress.sin_family = AF_INET;
serverAddress.sin_port = htons( 11979);
if( inet_pton( AF_INET, argv[1], &serverAddress.sin_addr) <= 0)
{
perror( "inet_pton error");
exit( 1);
}
w_connect( sockfd, ( struct sockaddr*) &serverAddress, sizeof( serverAddress));
str_cli( sockfd);
exit( 0);
}
void str_cli( int connfd)
{
char buffer[MAXLINE];
printf( "Enter the string to echo: ");
while( fgets( buffer, MAXLINE, stdin) > 0)
{
// Send string to echo server, and retrieve response
write( connfd, buffer, strlen( buffer));
read( connfd, buffer, MAXLINE - 1);
// Output echoed string
printf( "Echo response: %s\n", buffer);
printf( "Enter the string to echo: ");
}
}
追加情報が必要な場合、または不明な点がある場合はお知らせください
すべての返信に感謝します