基于linux網(wǎng)絡(luò)編程課程設(shè)計(jì)-資料下載頁
2025-06-18 18:19本頁面
【正文】 )。 while(RUNNING) { FD_ZERO(amp。readfds)。 FD_SET(0,amp。readfds)。 FD_SET(conn_fd,amp。readfds)。 = 7。 = 0。 max_fd = conn_fd。 if((ret = pselect(max_fd + 1,amp。readfds,NULL,NULL,amp。t_val,amp。sigset)) == 1) Err_sys(Server select:) else if(ret == 0) { Err_sys (Select timeout\n)。 continue。 } else { if(FD_ISSET(conn_fd,amp。readfds)) { memset(buffer_r,0,BUFFER_SIZE)。 rc = recv(conn_fd,buffer_r,BUFFER_SIZE,0)。 if(rc = 0) { fprintf(stderr,Server recv:%s\n,strerror(errno))。 FD_CLR(conn_fd,amp。readfds)。 close(conn_fd)。 } printf([Server recv]:%s\n,buffer_r)。 } //read set if(FD_ISSET(0,amp。readfds)) { memset(buffer_w,0,BUFFER_SIZE)。 printf([Server send]:)。 fflush(stdout)。 fgets(buffer_w,BUFFER_SIZE,stdin)。 wc = send(conn_fd,buffer_w,BUFFER_SIZE,0)。 if(wc = 0) fprintf(stderr,Server send:%s\n,strerror(errno))。 } //write set } } //while rw close(conn_fd)。 exit(EXIT_SUCCESS)。 }//else child } //while accept close(conn_fd)。 close(sock_fd)。 return 0。}(2) include int main (int argc, char *argv[]){ int sock_fd。 printf(Sftp protocol test! \n)。 struct sockaddr_in server_addr,client_addr。 socklen_t addrlen = ADDR_SIZE。 int wc = 1,rc = 1。 char buffer_r[BUFFER_SIZE],buffer_w[BUFFER_SIZE]。 int con_times = 0。 int i = 1。 struct hostent *host。 fd_set readfds。 struct timeval t_val。 int max_fd。 int ret。 if(argc != 2) { fprintf(stderr,Usage:%s ip\n,argv[0])。 exit(EXIT_FAILURE)。 } sock_fd = socket(AF_INET,SOCK_STREAM,0)。 if(sock_fd == 1) Err_sys(Client socket:) host = gethostbyname(argv[1])。 bzero(amp。server_addr,ADDR_SIZE)。 = AF_INET。 = htons(Server_port)。 = *((struct in_addr *)hosth_addr)。 while(connect(sock_fd,(struct sockaddr *)amp。server_addr,addrlen) == 1) { if(con_times 3) { printf(Client connecting ...........\n)。 sleep(3)。 } else { printf(Client connected failfully \n)。 exit(EXIT_FAILURE)。 } con_times++。 } //while while(RUNNING) { FD_ZERO(amp。readfds)。 FD_SET(0,amp。readfds)。 FD_SET(sock_fd,amp。readfds)。 = 1。 = 0。 max_fd = sock_fd。 fflush(stdin)。 if((ret = select(max_fd + 1,amp。readfds,NULL,NULL,amp。t_val)) == 1) Err_sys(Client select:) else if(ret == 0) { Err_sys (Select timeout\n)。 continue。 } else { printf(1111111111111111\n)。 if(FD_ISSET(0,amp。readfds)) { memset(buffer_w,0,BUFFER_SIZE)。 printf([Client send]:)。 fflush(stdout)。 fgets(buffer_w,BUFFER_SIZE,stdin)。 wc = send(sock_fd,buffer_w,BUFFER_SIZE,0)。 if(wc = 0) Err_sys(Client send:) } //read set if(FD_ISSET(sock_fd,amp。readfds)) { memset(buffer_r,0,BUFFER_SIZE)。 fflush(stdout)。 rc = recv(sock_fd,buffer_r,BUFFER_SIZE,0)。 if(rc = 0) Err_sys(Client recv:) printf([Client recv]:%s\n,buffer_r)。 } //write set }//else if } //while close(sock_fd)。 return 0。}（3）ifndef __NETWORK__H__define __NETWORK__H__ include include include include include include include include include sys/ include sys/ include sys/ include include include include sys/ include sys/ include arpa/ include netinet/ include include sys/ include sys/ pragma once pragma pack(4) define BUFFER_SIZE 1024 define Server_port 8888 define BACKLOG 5 define ADDR_SIZE sizeof(struct sockaddr_in) define RUNNING 1 define Err_sys(info) { fprintf(stderr,%s:%s\n,info,strerror(errno))。 exit(EXIT_FAILURE)。 } endif(4)編寫Makefile文件all: gcc g o tcp_server gcc g o tcp_client clean: rm tcp_server tcp_client(5)make
物理相關(guān)推薦
鄂ICP備17016276號(hào)-1