C语言 UDP socket 简单客户端 编程,急

C语言 UDP socket 简单客户端 编程,急,第1张

提一下,你那个地址不好用,换成了127.0.0.1,端口可以用,完全按照要求写的,编译没错误,调试通过:

gcc server.c -o server

gcc client.c -o client

打开2个控制台:一个运行 ./server 另一个运行 ./client

server.c:

========================================

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <arpa/inet.h>

#include <errno.h>

#define BUFFERSIZE 1024

typedef struct sockaddr SA

int main(void)

{

char buf[BUFFERSIZE]

struct sockaddr_in addr_s

struct sockaddr_in addr_c

int sockfd

socklen_t length

int i

if((sockfd = socket(AF_INET,SOCK_DGRAM,0)) == -1)

{

perror("socket fail")

return -1

}

memset(&addr_s,0,sizeof(addr_s))

addr_s.sin_family = AF_INET

addr_s.sin_addr.s_addr = inet_addr("127.0.0.1")

addr_s.sin_port = htons(31180)

if(bind(sockfd,(SA *)&addr_s,sizeof(addr_s)) == -1)

{

perror("bind fail")

return -1

}

length = sizeof(addr_c)

memset(buf,'\0',sizeof(buf))

if(recvfrom(sockfd,buf,sizeof(buf),0

,(SA *)&addr_c,&length) == -1)

{

perror("recvfrom fail")

}

printf("recvfrom client:%s\n",buf)

sendto(sockfd,buf,sizeof(buf),0,(SA *)&addr_c,sizeof(addr_c))

close(sockfd)

}

====================================

client.c:

====================================

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/types.h>

#include <sys/socket.h>

#include <arpa/inet.h>

#include <errno.h>

#define BUFFERSIZE 1024

typedef struct sockaddr SA

int main(void)

{

int sockfd

char buf[BUFFERSIZE]

struct sockaddr_in addr_s

if((sockfd = socket(AF_INET,SOCK_DGRAM,0)) == -1)

{

perror("socket fail")

return -1

}

memset(&addr_s,0,sizeof(addr_s))

addr_s.sin_family = AF_INET

addr_s.sin_addr.s_addr = inet_addr("127.0.0.1")

addr_s.sin_port = htons(31180)

memset(buf,'\0',sizeof(buf))

sprintf(buf,"abcde")

if(sendto(sockfd,buf,sizeof(buf)

,0,(SA *)&addr_s,sizeof(addr_s)) <0)

{

perror("sendto fail")

}

memset(buf,'\0',sizeof(buf))

recvfrom(sockfd,buf,sizeof(buf),0,NULL,NULL)

printf("recvfrom server:%s\n",buf)

close(sockfd)

}

UDP Server程序

1、编写UDP Server程序的步骤

(1)使用socket()来建立一个UDP socket,第二个参数为SOCK_DGRAM。

(2)初始化sockaddr_in结构的变量,并赋值。sockaddr_in结构定义:

struct sockaddr_in {

uint8_t sin_len

sa_family_t sin_family

in_port_t sin_port

struct in_addr sin_addr

char sin_zero[8]

}

这里使用“08”作为服务程序的端口,使用“INADDR_ANY”作为绑定的IP地址即任何主机上的地址。

(3)使用bind()把上面的socket和定义的IP地址和端口绑定。这里检查bind()是否执行成功,如果有错误就退出。这样可以防止服务程序重复运行的问题。

(4)进入无限循环程序,使用recvfrom()进入等待状态,直到接收到客户程序发送的数据,就处理收到的数据,并向客户程序发送反馈。这里是直接把收到的数据发回给客户程序。

2、udpserv.c程序内容:

#include <sys/types.h>

#include <sys/socket.h>

#include <string.h>

#include <netinet/in.h>

#include <stdio.h>

#include <stdlib.h>

#define MAXLINE 80

#define SERV_PORT 8888

void do_echo(int sockfd, struct sockaddr *pcliaddr, socklen_t clilen)

{

int n

socklen_t len

char mesg[MAXLINE]

for()

{

len = clilen

/* waiting for receive data */

n = recvfrom(sockfd, mesg, MAXLINE, 0, pcliaddr, &len)

/* sent data back to client */

sendto(sockfd, mesg, n, 0, pcliaddr, len)

}

}

int main(void)

{

int sockfd

struct sockaddr_in servaddr, cliaddr

sockfd = socket(AF_INET, SOCK_DGRAM, 0)/* create a socket */

/* init servaddr */

bzero(&servaddr, sizeof(servaddr))

servaddr.sin_family = AF_INET

servaddr.sin_addr.s_addr = htonl(INADDR_ANY)

servaddr.sin_port = htons(SERV_PORT)

/* bind address and port to socket */

if(bind(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) == -1)

{

perror("bind error")

exit(1)

}

do_echo(sockfd, (struct sockaddr *)&cliaddr, sizeof(cliaddr))

return 0

}

UDP Client程序

1、编写UDP Client程序的步骤

(1)初始化sockaddr_in结构的变量,并赋值。这里使用“8888”作为连接的服务程序的端口,从命令行参数读取IP地址,并且判断IP地址是否符合要求。

(2)使用socket()来建立一个UDP socket,第二个参数为SOCK_DGRAM。

(3)使用connect()来建立与服务程序的连接。与TCP协议不同,UDP的connect()并没有与服务程序三次握手。上面我们说了UDP是非连接的,实际上也可以是连接的。使用连接的UDP,kernel可以直接返回错误信息给用户程序,从而避免由于没有接收到数据而导致调用recvfrom()一直等待下去,看上去好像客户程序没有反应一样。

(4)向服务程序发送数据,因为使用连接的UDP,所以使用write()来替代sendto()。这里的数据直接从标准输入读取用户输入。

(5)接收服务程序发回的数据,同样使用read()来替代recvfrom()。

(6)处理接收到的数据,这里是直接输出到标准输出上。

2、udpclient.c程序内容:

#include <sys/types.h>

#include <sys/socket.h>

#include <string.h>

#include <netinet/in.h>

#include <stdio.h>

#include <stdlib.h>

#include <arpa/inet.h>

#include <unistd.h>

#define MAXLINE 80

#define SERV_PORT 8888

void do_cli(FILE *fp, int sockfd, struct sockaddr *pservaddr, socklen_t servlen)

{

int n

char sendline[MAXLINE], recvline[MAXLINE + 1]

/* connect to server */

if(connect(sockfd, (struct sockaddr *)pservaddr, servlen) == -1)

{

perror("connect error")

exit(1)

}

while(fgets(sendline, MAXLINE, fp) != NULL)

{

/* read a line and send to server */

write(sockfd, sendline, strlen(sendline))

/* receive data from server */

n = read(sockfd, recvline, MAXLINE)

if(n == -1)

{

perror("read error")

exit(1)

}

recvline[n] = 0/* terminate string */

fputs(recvline, stdout)

}

}

int main(int argc, char **argv)

{

int sockfd

struct sockaddr_in srvaddr

/* check args */

if(argc != 2)

{

printf("usage: udpclient <IPaddress>\n")

exit(1)

}

/* init servaddr */

bzero(&servaddr, sizeof(servaddr))

servaddr.sin_family = AF_INET

servaddr.sin_port = htons(SERV_PORT)

if(inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0)

{

printf("[%s] is not a valid IPaddress\n", argv[1])

exit(1)

}

sockfd = socket(AF_INET, SOCK_DGRAM, 0)

do_cli(stdin, sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr))

return 0

}

运行例子程序

1、编译例子程序

使用如下命令来编译例子程序:

gcc -Wall -o udpserv udpserv.c

gcc -Wall -o udpclient udpclient.c

编译完成生成了udpserv和udpclient两个可执行程序。

2、运行UDP Server程序

执行./udpserv &命令来启动服务程序。我们可以使用netstat -ln命令来观察服务程序绑定的IP地址和端口,部分输出信息如下:

Active Internet connections (only servers)

Proto Recv-Q Send-Q Local Address Foreign Address State

tcp 0 0 0.0.0.0:32768 0.0.0.0:* LISTEN

tcp 0 0 0.0.0.0:111 0.0.0.0:* LISTEN

tcp 0 0 0.0.0.0:6000 0.0.0.0:* LISTEN

tcp 0 0 127.0.0.1:631 0.0.0.0:* LISTEN

udp 0 0 0.0.0.0:32768 0.0.0.0:*

udp 0 0 0.0.0.0:8888 0.0.0.0:*

udp 0 0 0.0.0.0:111 0.0.0.0:*

udp 0 0 0.0.0.0:882 0.0.0.0:*

可以看到udp处有“0.0.0.0:8888”的内容,说明服务程序已经正常运行,可以接收主机上任何IP地址且端口为8888的数据。

如果这时再执行./udpserv &命令,就会看到如下信息:

bind error: Address already in use

说明已经有一个服务程序在运行了。

3、运行UDP Client程序

执行./udpclient 127.0.0.1命令来启动客户程序,使用127.0.0.1来连接服务程序,执行效果如下:

Hello, World!

Hello, World!

this is a test

this is a test

^d

输入的数据都正确从服务程序返回了,按ctrl+d可以结束输入,退出程序。

如果服务程序没有启动,而执行客户程序,就会看到如下信息:

$ ./udpclient 127.0.0.1

test

read error: Connection refused

说明指定的IP地址和端口没有服务程序绑定,客户程序就退出了。这就是使用connect()的好处,注意,这里错误信息是在向服务程序发送数据后收到的,而不是在调用connect()时。如果你使用tcpdump程序来抓包,会发现收到的是ICMP的错误信息。

本程序在 Windows 7 Visual Studio 2015 和 Linux Ubuntu 15.04 GCC 5.11 下均编译运行测试通过。

本程序支持 Windows 和 Linux 之间传送文件,如果要在 Windows 和 Linux 之间传送文件,文件名不能出现中文。

本程序支持无线 WiFi,支持 USB 收发器,但仅支持局域网内传送文件,传送文件需要输入对方的 IP 地址。

本程序包括服务器端和客户端,既可以发送文件又可以接收文件。如果要在同一台机器上测试需要同时打开两个程序。

Windows 下查看本机 IP 地址的命令是:

ipconfig

Linux 下查看本机 IP 地址的命令是:

ifconfig

以下是程序代码:

#include<stdio.h>

#include<stdlib.h>

#include<string.h>

#include<math.h>

#ifdef _MSC_VER

    #include<winsock2.h>

    #include<windows.h>

    #pragma comment(lib, "ws2_32.lib")

#else

    #include<pthread.h>

    #include<unistd.h>

    #include<signal.h>

    #include<sys/socket.h>

    #include<arpa/inet.h>

#endif

// 存放发送接收字符数组大小

#define SIZEA 65501

// 每次发送接收字节数

#define SIZEB 65500

typedef struct sockaddr_in SockAddrIn

SockAddrIn serverAddr, remoteAddr, clientAddr

// 端口号

int iServerPort, iClientPort

// 新建 socket 信息

int iUDP

// 字符串转整型

int strToInt(char* acStr)

{

    int i, iIndex = 0, iNum = 0, iSize = 0

    if(acStr[0] == '+' || acStr[0] == '-')

        iIndex = 1

    for(iSize=iIndex  iSize++)

        if(acStr[iSize] < '0' || acStr[iSize] > '9')

            break

    for(i=iIndex i<iSize i++)

        iNum += (int)pow(10, iSize - i - 1) * (acStr[i] - 48)

    if(acStr[0] == '-')

        iNum = - iNum

    return iNum

}

// 整型转字符串

void intToStr(int iInt, char* acStr)

{

    int iIndex = 0, iSize, iNum, iBit, i, j

    if(iInt < 0)

    {

        acStr[0] = '-'

        iInt = - iInt

        iIndex = 1

    }

    for(i=0  i++)

        if(iInt < pow(10, i))

            break

    iSize = i

    for(i=0 i<iSize i++)

    {

        iNum = pow(10, iSize - i - 1)

        iBit = iInt/iNum

        iInt -= iNum*iBit

        acStr[i + iIndex] = iBit + 48

    }

    if(iSize != 0)

        acStr[iSize + iIndex] = '\0'

    else

    {

        acStr[0] = '0'

        acStr[1] = '\0'

    }

}

void sleepUDP(int iSleep)

{

#ifdef _MSC_VER

    Sleep(iSleep)

#else

    usleep(iSleep*1000)

#endif

}

void openUDP(char* acIpAddr)

{

#ifdef _MSC_VER

    // Winsows 启用 socket

    WSADATA wsadata

    if(WSAStartup(MAKEWORD(1, 1), &wsadata) == SOCKET_ERROR)

    {

        printf("启用 socket 失败\n")

        exit(0)

    }

#endif

    // 新建 socket

    if((iUDP = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1)

    {

        printf("新建 socket 失败\n")

        exit(0)

    }

    // 清零

    memset(&serverAddr, 0, sizeof(serverAddr))

    memset(&clientAddr, 0, sizeof(clientAddr))

    // 设置协议 IP 地址及 Port

    serverAddr.sin_family = AF_INET

    serverAddr.sin_port = htons(iServerPort)

    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY)

    clientAddr.sin_family = AF_INET

    clientAddr.sin_port = htons(iClientPort)

    clientAddr.sin_addr.s_addr = inet_addr(acIpAddr)

    // 绑定端口,监听端口

    if(bind(iUDP, (struct sockaddr*)&serverAddr, sizeof(serverAddr)) == -1)

    {

        printf("绑定端口失败\n")

        exit(0)

    }

}

void closeUDP(void)

{

#ifdef _MSC_VER

    // Winsows 关闭 socket

    closesocket(iUDP)

    WSACleanup()

#endif

}

// 要发送的字符串

char acSendStr[SIZEA]

// 接收到的字符串

char acRecvStr[SIZEA]

// 请求信息

char acReq[SIZEA]

// 文件名字符串

char acFileName[SIZEA]

// 文件字节数字符串

char acFileSize[SIZEA]

int iSize, iNameSize

// 接收文件名

#ifdef _MSC_VER

DWORD WINAPI recvName(LPVOID p)

#else

void* recvName(void* arg)

#endif

{

    int iAddrSize = sizeof(remoteAddr)

    acReq[0] = 'n' acReq[1] = 'a' acReq[2] = 'm' acReq[3] = 'e' acReq[4] = '\0'

    acRecvStr[0] = '\0'

    printf("%s\n", "正在发送请求信息!")

    // 发送请求信息

    sendto(iUDP, acReq, strlen(acReq), 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

    // 每次发送请求信息后等待一段时间

    sleepUDP(10)

    // 接收文件名

    iSize = recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)

    return 0

}

// 接收文件

void recvFile(char* acDirName, char* acIpAddr)

{

    FILE* pFile = NULL

    int i, iFileSize, iRecvNum, iAddrSize = sizeof(remoteAddr)

    // 路径文件名

    char acDirAndFileName[SIZEA]

    openUDP(acIpAddr)

    // 接收文件名

    for()

    {

        // 创建线程

        #ifdef _MSC_VER

            HANDLE hThread

            DWORD threadId

            hThread = CreateThread(NULL, 0, recvName, 0, 0, &threadId)

            // 每次发送后等待一段时间

            sleepUDP(1000)

            // 强制终止线程

            TerminateThread(hThread, 0)

        #else

            pthread_t thread

            void* thread_arg = (pthread_t)0

            pthread_create(&thread, NULL, recvName, (void*)&thread_arg)

            // 每次发送后等待一段时间

            sleepUDP(1000)

            // 强制终止线程

            pthread_cancel(thread)

        #endif

        if(acRecvStr[0] != '\0')

        {

            acRecvStr[iSize] = '\0'

            printf("文件名为:%s\n", acRecvStr)

            break

        }

    }

    acDirAndFileName[0] = '\0'

    strcat(acDirAndFileName, acDirName)

    // 连接路径名和文件名

    strcat(acDirAndFileName, acRecvStr)

    // 如果已经有这个文件了就清空文件内容

    pFile = fopen(acDirAndFileName, "w")

    fclose(pFile)

    acReq[0] = 's' acReq[1] = 'i' acReq[2] = 'z' acReq[3] = 'e' acReq[4] = '\0'

    // 接收文件字节数

    for()

    {

        // 发送请求信息

        sendto(iUDP, acReq, strlen(acReq) + 1, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

        // 每次发送请求信息后等待一段时间

        sleepUDP(10)

        // 接收文件字节数

        acRecvStr[0] = '\0'

        iSize = recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)

        if(acRecvStr[0] != '\0')

        {

            acRecvStr[iSize] = '\0'

            iFileSize = strToInt(acRecvStr)

            printf("文件字节数为:%d\n", iFileSize)

            break

        }

    }

    // 以追加方式写入文件

    pFile = fopen(acDirAndFileName, "ab")

    // 文件分几次接收

    iRecvNum = iFileSize/SIZEB

    // 接收文件

    for(i=0 i<iRecvNum i++)

    {

        intToStr(i, acReq)

        for()

        {

            // 发送请求信息

            sendto(iUDP, acReq, strlen(acReq) + 1, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

            printf("%s\t正在接收文件的第 %d 段\n", acReq, i)

            // 每次发送请求信息后等待一段时间

            sleepUDP(10)

            // 接收一段文件

            iSize = recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)

            if(iSize == SIZEB)

            {

                // 以追加方式写入文件

                fwrite(acRecvStr, sizeof(char), iSize, pFile)

                break

            }

        }

    }

    // 接收文件剩余字节

    iSize = iFileSize%SIZEB

    if(iSize > 0)

    {

        acReq[0] = 'l' acReq[1] = 'a' acReq[2] = 's' acReq[3] = 't' acReq[4] = '\0'

        for()

        {

            // 发送请求信息

            sendto(iUDP, acReq, strlen(acReq) + 1, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

            // 每次发送请求信息后等待一段时间

            sleepUDP(10)

            // 接收文件剩余字节

            if(recvfrom(iUDP, acRecvStr, iSize, 0, (struct sockaddr*)&remoteAddr, &iAddrSize) == iSize)

            {

                // 以追加方式写入文件

                fwrite(acRecvStr, sizeof(char), iSize, pFile)

                break

            }

        }

    }

    printf("%s\n", "文件接收完毕!")

    // 关闭文件

    fclose(pFile)

    // 关闭连接

    closeUDP()

}

// 发送文件名

#ifdef _MSC_VER

DWORD WINAPI sendName(LPVOID p)

#else

void* sendName(void* arg)

#endif

{

    int iAddrSize = sizeof(remoteAddr)

    acRecvStr[0] = '\0'

    // 接收请求

    printf("%s\n", "正在接收请求信息!")

    recvfrom(iUDP, acRecvStr, 5, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)

    // 每次接收请求信息后等待一段时间

    sleepUDP(10)

    // 如果请求信息正确发送文件名

    if(acRecvStr[0] == 'n' && acRecvStr[1] == 'a' && acRecvStr[2] == 'm' && acRecvStr[3] == 'e' && acRecvStr[4] == '\0')

        sendto(iUDP, acFileName, iNameSize, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

    return 0

}

// 发送文件

void sendFile(char* acDirAndFileName, char* acIpAddr)

{

    int i, j, iFileSize, iSendNum, iAddrSize = sizeof(remoteAddr)

    FILE* pFile = NULL

    pFile = fopen(acDirAndFileName, "rb")

    fseek(pFile, 0, SEEK_END)

    // 文件字节数

    iFileSize = ftell(pFile)

    intToStr(iFileSize, acFileSize)

    //printf("%s\n", acDirAndFileName)

    // 获取文件名长度

    iSize = strlen(acDirAndFileName)

    for(i=iSize-1, iNameSize=0 i>=0 i--,iNameSize++)

        if(acDirAndFileName[i] == '\\' || acDirAndFileName[i] == '/')

            break

    //printf("%d\n", iNameSize)

    // 截取文件名

    for(i=0 i<iNameSize i++)

        acFileName[i] = acDirAndFileName[iSize - iNameSize + i]

    acFileName[iNameSize] = '\0'

    //printf("%s\n", acFileName)

    openUDP(acIpAddr)

    // 发送文件名

    for()

    {

    // 创建线程

    #ifdef _MSC_VER

        HANDLE hThread

        DWORD threadId

        hThread = CreateThread(NULL, 0, sendName, 0, 0, &threadId)

        // 每次接收请求信息后等待一段时间

        sleepUDP(1000)

        // 强制终止线程

        TerminateThread(hThread, 0)

    #else

        pthread_t thread

        void* thread_arg = (pthread_t)0

        pthread_create(&thread, NULL, sendName, (void*)&thread_arg)

        // 每次接收请求信息后等待一段时间

        sleepUDP(1000)

        // 强制终止线程

        pthread_cancel(thread)

    #endif

        // 如果请求信息正确退出循环

        if(acRecvStr[0] == 'n' && acRecvStr[1] == 'a' && acRecvStr[2] == 'm' && acRecvStr[3] == 'e' && acRecvStr[4] == '\0')

            break

    }

    // 发送文件字节数

    for()

    {

        acRecvStr[0] = '\0'

        // 接收请求

        recvfrom(iUDP, acRecvStr, 5, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)

        // 每次接收请求信息后等待一段时间

        sleepUDP(10)

        // 如果请求信息正确

        if(acRecvStr[0] == 's' && acRecvStr[1] == 'i' && acRecvStr[2] == 'z' && acRecvStr[3] == 'e' && acRecvStr[4] == '\0')

        {

            // 发送文件字节数

            sendto(iUDP, acFileSize, strlen(acFileSize), 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

            break

        }

    }

    iSendNum = iFileSize/SIZEB

    // 发送文件

    if(iSendNum > 0)

    {

        for(i=0i++)

        {

            acRecvStr[0] = '\0'

            // 接收请求

            recvfrom(iUDP, acRecvStr, SIZEB, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)

            printf("%s\t正在发送文件的第 %d 段\n", acRecvStr, i)

            // 每次接收请求信息后等待一段时间

            sleepUDP(10)

            fseek(pFile, strToInt(acRecvStr)*SIZEB, SEEK_SET)

            fread(acSendStr, 1, SIZEB, pFile)

            //printf("%s\n", acSendStr)

            // 发送一段文件

            sendto(iUDP, acSendStr, SIZEB, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

            if(strToInt(acRecvStr) >= iSendNum - 1)

                break

        }

    }

    // 发送文件剩余字节

    iSize = iFileSize%SIZEB

    if(iSize > 0)

    {

        for()

        {

            acRecvStr[0] = '\0'

            // 接收请求

            recvfrom(iUDP, acRecvStr, 5, 0, (struct sockaddr*)&remoteAddr, &iAddrSize)

            // 每次接收请求信息后等待一段时间

            sleepUDP(10)

            // 如果请求信息正确

            if(acRecvStr[0] == 'l' && acRecvStr[1] == 'a' && acRecvStr[2] == 's' && acRecvStr[3] == 't' && acRecvStr[4] == '\0')

            {

                fseek(pFile, iSendNum*SIZEB, SEEK_SET)

                fread(acSendStr, 1, iSize, pFile)

                //printf("%s\n", acSendStr)

                // 发送文件剩余字节

                sendto(iUDP, acSendStr, iSize, 0, (struct sockaddr*)&clientAddr, sizeof(clientAddr))

                break

            }

        }

    }

    printf("%s\n", "文件发送完毕!")

    // 关闭连接

    closeUDP()

}

int main(void)

{

    char acDirName[SIZEA]

    char acDirAndFileName[SIZEA]

    char acIpAddr[15]

    int i, iOption = 0, iSize = 0

    FILE* pFile = NULL

    char cLast = '\\'

option:

    printf("%s\n", "****************************************************\n本程序包括服务器端和客户端,既可以发送文件又可以接收文件。\n支持无线 WiFi,支持 USB 收发器,但仅支持局域网内传送文件。\n如果要在 Windows 和 Linux 之间传送文件,文件名不能出现中文。\n如果要在同一台机器上测试需要同时打开两个程序。\n****************************************************")

    printf("%s\n", "请输入选项,1.发送文件、2.接收文件。")

    scanf("%d", &iOption)

    // 发送文件

    if(iOption == 1)

    {

        iServerPort = 1025

        iClientPort = 1024

    fileName:

        printf("%s\n", "请输入需要发送的路径文件名。\nWindows 路径文件名格式:\t\tC:\\install.txt\nLinux 路径文件名格式:\t\t/home/install.txt")

        scanf("%s", acDirAndFileName)

        pFile = fopen(acDirAndFileName, "rb")

        if(pFile == NULL)

        {

            printf("%s\n", "读取文件失败,请重新输入文件名。")

            goto fileName

        }

        // 关闭文件

        fclose(pFile)

        printf("%s\n", "请输入接收文件方的 IP 地址,不能有空格。\n例如:\n192.168.1.104")

        scanf("%s", acIpAddr)

        sendFile(acDirAndFileName, acIpAddr)

    }

    // 接收文件

    else if(iOption == 2)

    {

        iServerPort = 1024

        iClientPort = 1025

    dirName:

        printf("%s\n", "请输入保存文件的路径名。\nWindows 路径名格式:\t\tC:\\img\\\nLinux 路径名格式:\t\t/home/")

        scanf("%s", acDirName)

        iSize = strlen(acDirName)

        // 检查是不是 Linux 路径名

        for(i=0 i<iSize i++)

        {

            if(acDirName[i] == '/')

            {

                cLast = '/'

                break

            }

        }

        // 检查路径名最后一个字符是不是 \ 或 /

        if(acDirName[iSize - 1] != cLast)

        {

            acDirName[iSize] = cLast

            acDirName[iSize + 1] = '\0'

        }

        acDirAndFileName[0] = '\0'

        strcat(acDirAndFileName, acDirName)

        strcat(acDirAndFileName, "a.txt")

        // 试探保存一个无关紧要的文件

        pFile = fopen(acDirAndFileName, "w")

        if(pFile == NULL)

        {

            printf("%s\n", "该路径无法创建文件,请重新输入路径名。")

            goto dirName

        }

        else

        {

            // 关闭文件

            fclose(pFile)

            // 删除文件

            remove(acDirAndFileName)

        }

        printf("%s\n", "请输入发送文件方的 IP 地址,不能有空格。\n例如:\n192.168.2.249")

        scanf("%s", acIpAddr)

        recvFile(acDirName, acIpAddr)

    }

    else

    {

        printf("%s\n", "没有这个选项,请重新输入。")

        goto option

    }

    return 0

}


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/yw/12145059.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-21
下一篇 2023-05-21

发表评论

登录后才能评论

评论列表(0条)

保存