- 論壇徽章:
- 0
|
下面代碼是局域網(wǎng)server同client相互發(fā)送數(shù)據(jù)代碼，代碼問題是為什么只能互相發(fā)送一次數(shù)據(jù)，再發(fā)送，對方就收不到了，求教！
代碼如下：
/******* 服務器程序 (server.c) ************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
int
main (int argc, char *argv[])
{
int sockfd, new_fd, pid, nbytes;
struct sockaddr_in server_addr;
struct sockaddr_in client_addr;
int sin_size, portnumber;
char buffer[1024 * 1024] = { 0 };
char hello[1024 * 1024] = { 0 };
if (argc != 2)
{
fprintf (stderr, "Usage:%s portnumber\a\n", argv[0]);
exit (1);
}
if ((portnumber = atoi (argv[1])) < 0)
{
perror ("atoi() error\n");
exit (1);
}
/* 服務器端開始建立socket描述符 */
if ((sockfd = socket (AF_INET, SOCK_STREAM, 0)) == -1)
{
perror ("socket() error\n");
exit (1);
}
/* 服務器端填充 sockaddr結構 */
bzero (&server_addr, sizeof (struct sockaddr_in));
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htonl (INADDR_ANY);
server_addr.sin_port = htons (portnumber);
/* 捆綁sockfd描述符 */
if (bind
(sockfd, (struct sockaddr *) (&server_addr),
sizeof (struct sockaddr)) == -1)
{
perror ("bind() error\n");
exit (1);
}
/* 監(jiān)聽sockfd描述符 */
if (listen (sockfd, 5) == -1)
{
perror ("listen() error\n");
exit (1);
}
while (1)
{
/* 服務器阻塞,直到客戶程序建立連接 */
sin_size = sizeof (struct sockaddr_in);
if ((new_fd =
accept (sockfd, (struct sockaddr *) (&client_addr),
&sin_size)) == -1)
{
perror ("accept() error\n");
exit (1);
}
fprintf (stderr, "Server get connection from %s\n",
inet_ntoa (client_addr.sin_addr));
if ((pid = fork ()) < 0)
{
perror ("fork() error\n");
exit (1);
}
else if (pid == 0)
{
if ((nbytes = read (new_fd, buffer, sizeof (buffer))) == -1)
{
perror ("read() error\n");
exit (1);
}
buffer[nbytes] = '\0';
fputs (buffer, stdout);
close (new_fd);
}
else
{
fgets (hello, sizeof (hello), stdin);
if (write (new_fd, hello, strlen (hello)) == -1)
{
perror ("write() error\n");
exit (1);
}
/* 這個通訊已經(jīng)結束 */
close (new_fd);
}
}
close (sockfd);
exit (0);
}
=================================================================================
/******* 客戶端程序 client.c ************/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <strings.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netdb.h>
int
main (int argc, char *argv[])
{
int sockfd, pid;
char buffer[1024 * 1024] = { 0 };
char hello[1024 * 1024] = { 0 };
struct sockaddr_in server_addr;
struct hostent *host;
int portnumber, nbytes;
if (argc != 3)
{
fprintf (stderr, "Usage:%s hostname portnumber\a\n", argv[0]);
exit (1);
}
if ((host = gethostbyname (argv[1])) == NULL)
{
perror ("gethostbyname() error\n");
exit (1);
}
if ((portnumber = atoi (argv[2])) < 0)
{
perror ("atoi() error\n");
exit (1);
}
/* 客戶程序開始建立 sockfd描述符 */
if ((sockfd = socket (AF_INET, SOCK_STREAM, 0)) == -1)
{
perror ("socket() error\n");
exit (1);
}
/* 客戶程序填充服務端的資料 */
bzero (&server_addr, sizeof (server_addr));
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons (portnumber);
server_addr.sin_addr = *((struct in_addr *) host->h_addr);
/* 客戶程序發(fā)起連接請求 */
if (connect
(sockfd, (struct sockaddr *) (&server_addr),
sizeof (struct sockaddr)) < 0)
{
perror ("connect() error\n");
exit (1);
}
/* 連接成功了 */
if ((pid = fork ()) < 0)
{
perror ("fork() error\n");
}
else if (pid > 0)
{
while (1)
{
nbytes = read (sockfd, buffer, 1024);
buffer[nbytes] = '\0';
fputs (buffer, stdout);
}
}
else
{
while (1)
{
fgets (hello, sizeof (hello), stdin);
if (write (sockfd, hello, strlen (hello)) < 0)
{
perror ("write() error\n");
exit (1);
}
}
}
/* 結束通訊 */
close (sockfd);
exit (0);
} |
|
免費注冊
發(fā)表于 2012-07-29 21:19
回復 