C++ 实现TCP文件传输时出现问题
我最近用C++简单的实现了一下TCP传输文件的实例
前期测试单向传输时都没有什么问题,但是目前测试双向传输时发现存在程序假死的问题,查错了几天但也没有发现什么问题。

实现的具体过程是两部分:1.服务器端先从客户端收一个文件并且保存在本地2.服务器端再发送一个文件给客户端并且客户端将这个文件保存在本地。

运行过程中,在1->2的过程中间,程序会卡死。客户端这边显示已经发送完毕,服务器端显示有接收到数据,但是会卡在最后一个数据流接收完成的位置,不会继续往下执行语句,也无法显示文件接收完毕的提示。

我用VS尝试调试了一下,发现客户端这边是正常的,但是服务器那边在接收到最后一个文件流以后程序会直接跑飞,不知道运行到哪一条语句了。
我也尝试把1,2两个部分单独拿出来,让服务器端和客户端单独进行收发,就没有出现什么问题。

还想请问各位大牛这是出现什么问题了

代码本来是在linux上出现问题的,为了方便调试我就大致修改了一下搬到windows上,但是问题还是一样出现。
代码如下:
服务器:
#include<stdio.h>  
#include<stdlib.h>  
#include<string.h>  
#include<iostream>  
#include<sys/types.h>   
#include<winsock2.h>  
#include <errno.h>
#pragma comment(lib, "ws2_32.lib")
#define PORT 22222
#pragma warning(disable:4996)
#define maxline 1024    
using namespace std;
int main(int argc, char **argv)
{
    SOCKET ser_sockfd, cli_sockfd;
    sockaddr_in ser_addr;
    sockaddr_in cli_addr;
    FILE *fp;
    FILE *result;
    char buf[maxline];
    int recv_len, write_len, read_len, send_len;
    WSADATA wsaData;
    int iRet = 0;
    iRet = WSAStartup(MAKEWORD(2, 2), &wsaData);
    if (iRet != 0)
    {
        cout << "WSAStartup(MAKEWORD(2, 2), &wsaData) execute failed!" << endl;;
        return -1;
    }
    if (2 != LOBYTE(wsaData.wVersion) || 2 != HIBYTE(wsaData.wVersion))
    {
        WSACleanup();
        cout << "WSADATA version is not correct!" << endl;
        return -1;
    }
    ser_sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (ser_sockfd == INVALID_SOCKET)
    {
        printf("socket error:%s\n", strerror(errno));
        return -1;
    }

    ser_addr.sin_family = AF_INET;
    ser_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    ser_addr.sin_port = htons(PORT);
    iRet = bind(ser_sockfd, (struct sockaddr *)&ser_addr, sizeof(ser_addr));
    if (iRet == SOCKET_ERROR)
    {
        printf("bind error:%s\n", strerror(errno));
        return -1;
    }


    while (1)
    {
        if ((fp = fopen("1.wav", "wb")) == NULL)
        {
            printf("open file failed\n");
            exit(0);
        }

        iRet = listen(ser_sockfd, 5);
        if (iRet == SOCKET_ERROR)
        {
            printf("listen error\n");
            return -1;
        }

        printf("listen the port:\n");

        int addlen = sizeof(sockaddr);
        cli_sockfd = accept(ser_sockfd, (struct sockaddr *)&cli_addr, &addlen);
        if (cli_sockfd == INVALID_SOCKET)
        {
            printf("accept error\n");
        }

        memset(buf,'\0',maxline);
        printf("waiting for client...\n");
        while ((recv_len = recv(cli_sockfd, buf, maxline, 0))>0)
        {
            if (recv_len==-1)
            {
                printf("recv error\n");
                break;
            }
            printf("#");
            write_len = fwrite(buf, sizeof(char), recv_len, fp);
            if (write_len < recv_len)
            {
                printf("Write file failed\n");
                break;
            }
            memset(buf,'\0', maxline);
        }
        printf("\nfinsih recieve\n");
        printf("decode finish\n");
        if ((result = fopen("result.txt", "rb")) == NULL)
        {
            printf("Open result file failed\n");
            exit(0);
        }
        memset(buf,'\0', maxline);
        while ((read_len = fread(buf, sizeof(char), maxline, result))>0)
        {
            printf("#");
            send_len = send(cli_sockfd, buf, read_len, 0);
            if (send_len==-1)
            {
                printf("send failed\n");
                exit(0);
            }
            memset(buf,'\0', maxline);
        }
        fclose(result);

        fclose(fp);
        printf("\nresult send finfish\n");
        closesocket(cli_sockfd);
    }

    closesocket(ser_sockfd);

    return 0;
}

客户端:

#include<stdio.h> 
#include<stdlib.h>  
#include<cstring>  
#include<iostream>  
#include<Ws2tcpip.h>
#include<sys/types.h>  
#include<winsock2.h>
#pragma warning(disable:4996)
#pragma comment(lib,"ws2_32.lib")  
#define PORT 22222
#define maxline 1024 
using namespace std;
int main(int argc, char **argv)
{
    //加载套接字库  
    WSADATA wsaData;
    int iRet = 0;
    iRet = WSAStartup(MAKEWORD(2, 2), &wsaData);
    if (iRet != 0)
    {
        cout << "WSAStartup(MAKEWORD(2, 2), &wsaData) execute failed!" << endl;
        return -1;
    }
    if (2 != LOBYTE(wsaData.wVersion) || 2 != HIBYTE(wsaData.wVersion))
    {
        WSACleanup();
        cout << "WSADATA version is not correct!" << endl;
        return -1;
    }
    SOCKET sockfd;
    sockaddr_in addr_ser;
    int send_len, read_len, recv_len, write_len;
    char buf[maxline];
    FILE *fp;
    FILE *result;
    memset(buf, '\0', maxline);
    if ((fp=fopen( "1.wav ","rb")) == NULL)
    {
        printf("Open file failed\n");
        exit(0);
    }
    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd == INVALID_SOCKET)
    {
        printf("socket error\n");
        return -1;
    }

    addr_ser.sin_family = AF_INET;
    inet_pton(AF_INET,"192.168.20.113", (void *)&addr_ser.sin_addr.s_addr);
    addr_ser.sin_port = htons(PORT);
    iRet = connect(sockfd, (sockaddr *)&addr_ser, sizeof(addr_ser));
    if (iRet != 0)
    {
        printf("connect error\n");
        return -1;
    }

    printf("connect with server...\n");


    memset(buf,'\0', maxline);
    while ((read_len = fread(buf, sizeof(char), maxline, fp))>0)
    {
        send_len = send(sockfd, buf, read_len, 0);
        if (send_len==-1)
        {
            printf("send failed\n");
            exit(0);
        }
        memset(buf,'\0', maxline);
    }
    printf("send finish\n");
    memset(buf,'\0', maxline);
    printf("waiting for server...\n");

    if ((result = fopen("result.txt", "wb")) == NULL)
    {
        printf("Open file failed\n");
        exit(0);
    }
    while ((recv_len = recv(sockfd, buf, maxline, 0))>0)
    {
        if (recv_len==-1)
        {
            printf("recv error\n");
            break;
        }
        printf("#");
        write_len = fwrite(buf, sizeof(char), recv_len, result);
        if (write_len < recv_len)
        {
            printf("Write file failed\n");
            break;
        }
        memset(buf,'\0', maxline);
    }
    printf("\nfinsih recieve\n");
    fclose(result);
    closesocket(sockfd);
    fclose(fp);
    return 0;
}


3个回答

    ser_sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (ser_sockfd == INVALID_SOCKET)
    {
        printf("socket error:%s\n", strerror(errno));
        return -1;
    }
    int nNetTimeout=100;//1秒,   // 在这里设置超时就OK了。。。
    setsockopt(ser_sockfd, SOL_SOCKET, SO_RCVTIMEO, (char *)&nNetTimeout, sizeof(int));
Asuka_S
Asuka_S 之前用网上一个简单的TCP程序做测试的时候,却没有这种情况出现,那个程序实现有点类似聊天系统,服务器端和客户端一人一句话进行传输并且打印到屏幕上
接近 3 年之前 回复
Asuka_S
Asuka_S 非常感谢!添加有确实有效,但是我还是蛮好奇导致出现接收端超时的原因具体是什么呢,还望赐教
接近 3 年之前 回复

发个个人写的链接,找找原因~
http://blog.csdn.net/what951006/article/details/69569592

http://www.cnblogs.com/churi/archive/2013/02/27/2935427.html

你说的类似这样。。基本send和recv都是一一对应关系。。。

你的这种就是,client只管发数据,而没有告知数据已经结束。。。server只管接收,根本不知道何时接受完,也没有超时定义。。那就一直处以等待接受状态。。
TCP本身就是阻塞操作。。。

Asuka_S
Asuka_S 明白了 感谢解答!
接近 3 年之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
C++ 实现TCP文件传输时出现问题

我最近用C++简单的实现了一下TCP传输文件的实例 前期测试单向传输时都没有什么问题,但是目前测试双向传输时发现存在程序假死的问题,查错了几天但也没有发现什么问题。 实现的具体过程是两部分:1.服务器端先从客户端收一个文件并且保存在本地2.服务器端再发送一个文件给客户端并且客户端将这个文件保存在本地。 运行过程中,在1->2的过程中间,程序会卡死。客户端这边显示已经发送完毕,服务器端显示有接收到数据,但是会卡在最后一个数据流接收完成的位置,不会继续往下执行语句,也无法显示文件接收完毕的提示。 我用VS尝试调试了一下,发现客户端这边是正常的,但是服务器那边在接收到最后一个文件流以后程序会直接跑飞,不知道运行到哪一条语句了。 我也尝试把1,2两个部分单独拿出来,让服务器端和客户端单独进行收发,就没有出现什么问题。 还想请问各位大牛这是出现什么问题了 代码本来是在linux上出现问题的,为了方便调试我就大致修改了一下搬到windows上,但是问题还是一样出现。 代码如下: 服务器: ``` #include<stdio.h> #include<stdlib.h> #include<string.h> #include<iostream> #include<sys/types.h> #include<winsock2.h> #include <errno.h> #pragma comment(lib, "ws2_32.lib") #define PORT 22222 #pragma warning(disable:4996) #define maxline 1024 using namespace std; int main(int argc, char **argv) { SOCKET ser_sockfd, cli_sockfd; sockaddr_in ser_addr; sockaddr_in cli_addr; FILE *fp; FILE *result; char buf[maxline]; int recv_len, write_len, read_len, send_len; WSADATA wsaData; int iRet = 0; iRet = WSAStartup(MAKEWORD(2, 2), &wsaData); if (iRet != 0) { cout << "WSAStartup(MAKEWORD(2, 2), &wsaData) execute failed!" << endl;; return -1; } if (2 != LOBYTE(wsaData.wVersion) || 2 != HIBYTE(wsaData.wVersion)) { WSACleanup(); cout << "WSADATA version is not correct!" << endl; return -1; } ser_sockfd = socket(AF_INET, SOCK_STREAM, 0); if (ser_sockfd == INVALID_SOCKET) { printf("socket error:%s\n", strerror(errno)); return -1; } ser_addr.sin_family = AF_INET; ser_addr.sin_addr.s_addr = htonl(INADDR_ANY); ser_addr.sin_port = htons(PORT); iRet = bind(ser_sockfd, (struct sockaddr *)&ser_addr, sizeof(ser_addr)); if (iRet == SOCKET_ERROR) { printf("bind error:%s\n", strerror(errno)); return -1; } while (1) { if ((fp = fopen("1.wav", "wb")) == NULL) { printf("open file failed\n"); exit(0); } iRet = listen(ser_sockfd, 5); if (iRet == SOCKET_ERROR) { printf("listen error\n"); return -1; } printf("listen the port:\n"); int addlen = sizeof(sockaddr); cli_sockfd = accept(ser_sockfd, (struct sockaddr *)&cli_addr, &addlen); if (cli_sockfd == INVALID_SOCKET) { printf("accept error\n"); } memset(buf,'\0',maxline); printf("waiting for client...\n"); while ((recv_len = recv(cli_sockfd, buf, maxline, 0))>0) { if (recv_len==-1) { printf("recv error\n"); break; } printf("#"); write_len = fwrite(buf, sizeof(char), recv_len, fp); if (write_len < recv_len) { printf("Write file failed\n"); break; } memset(buf,'\0', maxline); } printf("\nfinsih recieve\n"); printf("decode finish\n"); if ((result = fopen("result.txt", "rb")) == NULL) { printf("Open result file failed\n"); exit(0); } memset(buf,'\0', maxline); while ((read_len = fread(buf, sizeof(char), maxline, result))>0) { printf("#"); send_len = send(cli_sockfd, buf, read_len, 0); if (send_len==-1) { printf("send failed\n"); exit(0); } memset(buf,'\0', maxline); } fclose(result); fclose(fp); printf("\nresult send finfish\n"); closesocket(cli_sockfd); } closesocket(ser_sockfd); return 0; } ``` 客户端: ``` #include<stdio.h> #include<stdlib.h> #include<cstring> #include<iostream> #include<Ws2tcpip.h> #include<sys/types.h> #include<winsock2.h> #pragma warning(disable:4996) #pragma comment(lib,"ws2_32.lib") #define PORT 22222 #define maxline 1024 using namespace std; int main(int argc, char **argv) { //加载套接字库 WSADATA wsaData; int iRet = 0; iRet = WSAStartup(MAKEWORD(2, 2), &wsaData); if (iRet != 0) { cout << "WSAStartup(MAKEWORD(2, 2), &wsaData) execute failed!" << endl; return -1; } if (2 != LOBYTE(wsaData.wVersion) || 2 != HIBYTE(wsaData.wVersion)) { WSACleanup(); cout << "WSADATA version is not correct!" << endl; return -1; } SOCKET sockfd; sockaddr_in addr_ser; int send_len, read_len, recv_len, write_len; char buf[maxline]; FILE *fp; FILE *result; memset(buf, '\0', maxline); if ((fp=fopen( "1.wav ","rb")) == NULL) { printf("Open file failed\n"); exit(0); } sockfd = socket(AF_INET, SOCK_STREAM, 0); if (sockfd == INVALID_SOCKET) { printf("socket error\n"); return -1; } addr_ser.sin_family = AF_INET; inet_pton(AF_INET,"192.168.20.113", (void *)&addr_ser.sin_addr.s_addr); addr_ser.sin_port = htons(PORT); iRet = connect(sockfd, (sockaddr *)&addr_ser, sizeof(addr_ser)); if (iRet != 0) { printf("connect error\n"); return -1; } printf("connect with server...\n"); memset(buf,'\0', maxline); while ((read_len = fread(buf, sizeof(char), maxline, fp))>0) { send_len = send(sockfd, buf, read_len, 0); if (send_len==-1) { printf("send failed\n"); exit(0); } memset(buf,'\0', maxline); } printf("send finish\n"); memset(buf,'\0', maxline); printf("waiting for server...\n"); if ((result = fopen("result.txt", "wb")) == NULL) { printf("Open file failed\n"); exit(0); } while ((recv_len = recv(sockfd, buf, maxline, 0))>0) { if (recv_len==-1) { printf("recv error\n"); break; } printf("#"); write_len = fwrite(buf, sizeof(char), recv_len, result); if (write_len < recv_len) { printf("Write file failed\n"); break; } memset(buf,'\0', maxline); } printf("\nfinsih recieve\n"); fclose(result); closesocket(sockfd); fclose(fp); return 0; } ```

C语言socket建立的简单文件传输问题

# 客户端发送文件 #include<stdio.h> #include<sys/stat.h> #include<sys/socket.h> #include<arpa/inet.h> #include<unistd.h> #include<fcntl.h> #include<string.h> int main(int argc,char **argv) { ssize_t i=1; char buf[512]; int fp; int ret; int socket_client; struct sockaddr_in addr_in; socket_client = socket(AF_INET,SOCK_STREAM,0);//创建套接字 if(socket_client<0){ perror("socket err"); return -1; } addr_in.sin_family = AF_INET; addr_in.sin_port = htons(9001); addr_in.sin_addr.s_addr = inet_addr("192.168.1.77"); ret = connect(socket_client,(struct sockaddr *)&addr_in,sizeof(addr_in));//链接 if(ret<0){ perror("connect err"); return -2; } scanf("%s",buf);//写入文件名 ret = send(socket_client,&buf,sizeof(buf),0);//发送文件名 if(ret<0){ perror("send err"); return -11; } fp = open(buf,O_RDONLY);//打开要发送的文件 if(fp<0){ fprintf(stderr,"open err\n"); return -1; } while(1){ if(i==0){ break; } memset(buf,0,sizeof(buf));//空间清0 i = read(fp,buf,sizeof(buf));//读文件到buf if(i<0){ perror("read err"); return -7; }else if(i==0){ break; } printf("%s\n",buf);//打印一遍用于观察 ret = send(socket_client,buf,sizeof(buf),0);//发送读取到的内容 if(ret<0){ perror("send err"); return -8; } printf("%d\n",ret);//打印发送的大小 sleep(1); } close(socket_client); return 0; } ## 服务器接收文件 #include<stdio.h> #include<sys/types.h> #include<sys/socket.h> #include<sys/stat.h> #include<arpa/inet.h> #include<unistd.h> #include<string.h> #include<stdlib.h> #include<fcntl.h> int main(int aegc,char **argv) { char buf[512]; ssize_t i; int fp; int ret; int socket_sever; int socket_client; struct sockaddr_in addr_in; socket_sever = socket(AF_INET,SOCK_STREAM,0);//定义socket套接字 if(socket_sever<0){ perror("socket err"); return -1; } addr_in.sin_family = AF_INET; addr_in.sin_port = htons(9001); addr_in.sin_addr.s_addr = inet_addr("192.168.1.77"); ret = bind(socket_sever,(struct sockaddr *)&addr_in,sizeof(addr_in));//绑定 if(ret<0){ perror("bind err"); return -2; } ret = listen(socket_sever,5);//监听 if(ret<0){ perror("listen err"); return -3; } socket_client = accept(socket_sever,NULL,NULL);//建立链接 if(socket_client<0){ perror("accept err"); return -4; } ret = recv(socket_client,&buf,sizeof(buf),0);//接收文件明 if(ret<0){ perror("recv err"); return -6; } fp = open(buf,O_WRONLY | O_CREAT | O_APPEND,0644);//创建并打开文件 if(fp<0){ fprintf(stderr,"open err"); return -1; } while(1){ if(i==0){ break; } memset(buf,0,sizeof(buf));//接收空间清0 ret = recv(socket_client,buf,sizeof(buf),0);//接收 if(ret<0){ perror("recv err"); return -6; }else if(ret==0){ break; } printf("%s\n",buf);//打印一遍用于观察 i = write(fp,buf,sizeof(buf));//写入打开的文件 if(i<0){ perror("write err"); return -13; }else if(i==0){ break;} sleep(1); } close(socket_sever); close(socket_client); } 问题出现在写入完成后末尾出现连续的^@^@^@^@^@^@^@^@符号,占用空间

QT 多线程 TCP文件传输 接收不完全

最近学习文件传输 然后写了一个同窗口的发送文件和接收 小文件大文件都没问题 然后又想弄个多线程的文件传输 然后就遇到问题了 1. 首先传输小文件没问题,然后传送一般的不是很大的文件的时候就会出现客户端发送完毕,而服务器没有接收完的情况,这是什么原因? ![图片说明](https://img-ask.csdn.net/upload/201909/17/1568713267_242360.png) 2. 然后传输大文件时,会出现程序崩溃的情况,这个是啥情况 ![图片说明](https://img-ask.csdn.net/upload/201909/17/1568713442_570465.png)![图片说明](https://img-ask.csdn.net/upload/201909/17/1568713456_37472.png) 3. 再然后 在线程中如何关闭socket? 我在槽函数中关闭的话,会报错 好像说是 QSocketNotifier: Socket notifiers cannot be enabled or disabled from another thread ASSERT failure in QCoreApplication::sendEvent: "Cannot send events to objects owned by a different thread. Current thread 0x0x246e9610. Receiver '' (of type 'QNativeSocketEngine') was created in thread 0x0x2462d1d0", file [url=kernel\qcoreapplication.cpp, line 578]kernel\qcoreapplication.cpp, line 578[/url] ![图片说明](https://img-ask.csdn.net/upload/201909/17/1568713523_448601.png)![图片说明](https://img-ask.csdn.net/upload/201909/17/1568713534_796603.png)

有没有哥们做过C++builder tcpsocket大文件的传输,

有没有哥们做过C++builder tcpsocket大文件的传输,比如客户端传送文件到服务器,需要分包,小弟,没做过这这方面的求教,最好能给出例子

QT中,如果要使用TCP协议实现文件传输功能,可以使用QNetworkAccessManager类吗,还是只能使用QTcpSocket和QTcpServer

QT中,如果要使用TCP协议实现文件传输功能,可以使用QNetworkAccessManager类吗,还是只能使用QTcpSocket和QTcpServer,QNetworkAccessManager建立连接是基于什么协议

如何在golang中通知TCP客户端文件的结尾?

<div class="post-text" itemprop="text"> <p>I want to send a file through TCP in golang. here's my server code:</p> <pre><code> c is connected *net.TCPConn file, _ := os.Open(fn) defer file.Close() io.Copy(c, file) // c.CloseWrite() </code></pre> <p>and client:</p> <pre><code> as above, c is connected *net.TCPConn file, _ := os.Create("file.txt") defer file.Close() io.Copy(file, c) </code></pre> <p>my question is: in this way, the client can not receive the EOF of the file</p> <p>so, <code>io.Copy</code> blocked. I have to call <code>c.CloseWrite</code> to notify client that the file is over.</p> <p>If I want to send files, this will not work, How can I solve this?</p> </div>

C/C++ socket tcp 发送和接收数据问题

客户端和服务器之间发送的一个数据正常,但当发送第二个数据后便出现了问题。求大神帮忙看一哈: 代码如下: client端: #include <WINSOCK2.H> #include <STDIO.H> #include <iostream> using namespace std; #pragma comment(lib,"ws2_32.lib") int main(int argc, char* argv[]) { WORD sockVersion = MAKEWORD(2,2); WSADATA data; if(WSAStartup(sockVersion, &data) != 0) { return 0; } SOCKET sclient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if(sclient == INVALID_SOCKET) { printf("invalid socket !"); return 0; } sockaddr_in serAddr; serAddr.sin_family = AF_INET; serAddr.sin_port = htons(1000); serAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); /**************************************** int WSA_return; WSADATA WSAData; WSA_return=WSAStartup(0x0101,&WSAData); hostent *host_entry;// 结构指针 char host_name[256] ="manage.dgjgw.cn"; if(WSA_return==0) { host_entry=gethostbyname(host_name);// 即要解析的域名或主机名 printf("%s\n", host_name); if(host_entry!=0) { printf("解析ip地址: "); printf("%s",inet_ntoa(*((struct in_addr*)host_entry->h_addr))); } } serAddr.sin_addr.S_un.S_addr = inet_addr((char*)inet_ntoa(*((struct in_addr*)host_entry->h_addr))); ****************************************/ //接收缓存区 int nRecvBuf=32*1024;//设置为32K setsockopt(sclient,SOL_SOCKET,SO_RCVBUF,(const char*)&nRecvBuf,sizeof(int)); //发送缓冲区 int nSendBuf=32*1024;//设置为32K setsockopt(sclient,SOL_SOCKET,SO_SNDBUF,(const char*)&nSendBuf,sizeof(int)); printf("连接中》》》》》》》》》\n"); //连接1 if (connect(sclient, (sockaddr *)&serAddr, sizeof(serAddr)) == SOCKET_ERROR) { printf("connect error !\n"); closesocket(sclient); return 0; } else { printf(" connect success !\n"); } //连接2 while (true) { char sendData[10] ={0x05,0x01,0x33,0x33,0x33,0x33,0x33,0x33,0x33,0x33}; char sendData1[2] ={0x05,0x03}; cout<<"请输入指令"<<endl; int a=0; cin>>a; switch(a) { case 1: printf("发送注册消息\n"); send(sclient, sendData, strlen(sendData), 0); break; case 2: printf("发送心跳消息\n"); send(sclient, sendData1, strlen(sendData1), 0); break; default : cout<<"输入错误"<<endl; break; } char recData[2]; memset(recData,0,2); int ret=0; ret = recv(sclient, recData, 2, 0); if(ret > 0) { printf("信息发送成功,回执如下\n"); for(int i=0;i<=ret;i++) { printf("%x",recData[i]); } printf("\n"); } else { printf("信息发送失败,关闭客户端\n"); break; } memset(recData,0,2); closesocket(sclient); } system("pause"); closesocket(sclient); WSACleanup(); return 0; } sever端: //#include "stdafx.h" #include <stdio.h> #include <winsock2.h> #pragma comment(lib,"ws2_32.lib") int main(int argc, char* argv[]) { //初始化WSA WORD sockVersion = MAKEWORD(2,2); WSADATA wsaData; if(WSAStartup(sockVersion, &wsaData)!=0) { return 0; } //创建套接字 SOCKET slisten = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if(slisten == INVALID_SOCKET) { printf("socket error !"); return 0; } //绑定IP和端口 sockaddr_in sin; sin.sin_family = AF_INET; sin.sin_port = htons(1000); sin.sin_addr.S_un.S_addr = INADDR_ANY; if(bind(slisten, (LPSOCKADDR)&sin, sizeof(sin)) == SOCKET_ERROR) { printf("bind error !"); } //开始监听 if(listen(slisten, 5) == SOCKET_ERROR) { printf("listen error !"); return 0; } //循环接收数据 SOCKET sClient; sockaddr_in remoteAddr; int nAddrlen = sizeof(remoteAddr); char revData[255]; while (true) { printf("等待连接...\n"); sClient = accept(slisten, (SOCKADDR *)&remoteAddr, &nAddrlen); if(sClient == INVALID_SOCKET) { printf("accept error !"); continue; } printf("接受到一个连接:%s \r\n", inet_ntoa(remoteAddr.sin_addr)); //接收数据 char revData[10]; memset(revData,0,10); int ret= recv(sClient, revData, 10, 0); if(ret > 0) { printf("消息接收成功:\n"); for(int i=0;i<ret;i++) { printf("%x",revData[i]); } printf("\n"); } else { printf("消息接收失败:\n"); } while(revData[0]==0x05&&revData[1]==0x01&&revData[2]==0x33&&revData[3]==0x33&&revData[4]==0x33 &&revData[5]==0x33&&revData[6]==0x33&&revData[7]==0x33&&revData[8]==0x33&&revData[9]==0x33) { printf("注册消息接收成功:\n"); for(int i=0;i<ret;i++) { printf("%x",revData[i]); } printf("\n"); char sendData1[2]; sendData1[0]=0x05; sendData1[1]=0x02; send(sClient, sendData1, 2, 0); break; } while(revData[0]==0x05&&revData[1]==0x03) { printf("心跳消息接收成功:\n"); for(int i=0;i<2;i++) { printf("%x",revData[i]); } printf("\n"); char sendData[2]; sendData[0]=0x05; sendData[1]=0x04; send(sClient, sendData, 2, 0); break; } } closesocket(sClient); closesocket(slisten); WSACleanup(); return 0; }

在Linux下用c语言编写,用UDP和TCP两种方式

用UDP和TCP两种方式,编写C/S结构程序,能上传下载暂停续传文件,客户端能显示进度,能随时终止上传下载,要求传输速度尽可能快、控制和传输独立线程处理 目的:熟悉阻塞和非阻塞SOCKET编程,熟悉如何安全使用线程,如何同步和互斥

通过TCP Golang发送多个文件-简单协议

<div class="post-text" itemprop="text"> <p>I'm trying to build a simple protocol to send files over TCP in golang. After reading some stuff I decided to use GOB package to send a header with information about file being sent and then file in using raw socket. Between messages I'm using a delimiter ("/r/n") So the sendflow looks like that: Client(sends a file)(C) Server(S)</p> <ul> <li>(C)Reading file metadata(filesize, filename, etc)</li> <li>(C)Encoding file metadata into struct </li> <li>(C)Intialize connection with server</li> <li>(C)Send encoded gob</li> <li>(S)Receive a gob and decode</li> <li>(C)Send a delimiter</li> <li>(S)Receive a delimiter</li> <li>(C)Start sending file using buffer (1024)</li> <li>(S)Start receiving file and saving to created file until size from header message will be exceeded.</li> <li>(C)Send a delimiter</li> <li>(S)Receive a delimiter</li> <li>(C)Close connection</li> </ul> <p>Hopefully I explained it well. A problem is that in my unittests when I'm checking checksums of file being transfered sometimes I have wrong files it looks like sometimes the delimiter is added also. My question is if my simple protocol does make sense, if not could someone give my some advices how to build it to be robust and reliable.</p> <p>Thanks in advance!</p> </div>

多线程TCP/IP网络编程

编写一个socket通信程序,win32控制台的,可以发送、接收消息和文件。要多线程。C语言的。 客户端和服务端各要有怎样的思路,求指导! --------------------------- 目前思路大致是,服务端,两个子线程,主线程接受连接,一个子线程发送消息,一个子线程接收消息。 客户端,主线程连接,一个子线程发送消息,一个子线程接收消息。 现在有个问题,连接多个客户端后,客户端发送的消息会乱掉,服务器又怎么分辨客户端给特定的客户端发送消息。 还有,怎么传输文件。

tcp服务器中转,服务器转发怎么实现

两个不同局域网的客户端A、B,一个公网服务器,A多线程向服务器发送文件,服务器收到文件转发给B,请问服务器端转发该怎么实现,需要同时传送多个文件

tcp报文端,再传输时,如何自定义包头,或者说,只发送不含数据的数据段

# 10、数据部分: TCP 报文段中的数据部分是可选的。在一个连接建立和一个连接终止时,双方交换的报文段仅有 TCP 首部。如果一方没有数据要发送,也使用没有任何数据的首部来确认收到的数据。在处理超时的许多情况中,也会发送不带任何数据的报文段。 这段话 来自网上 ; 我想知道 java如何在设置TCP的包头,使得在通信时,回复服务器的数据报只有TCP的包头。

linux,c,socket,udp文件传输

client端接收数据时,buffer中数据存在,但是在fwrite写入的时候数据丢失了,请问有什么原因可能导致这个问题(丢失的部分都是在整个文件的最后部分)

利用socket编程,实现windows 和Linux 互相传输数据。

利用socket编程,实现windows 和Linux 互相传输数据。以windows为client 以Linux为server。在windows发送命令过去,将数据传输过去,在Linux上接受。进而在windows上再次发送一条命令过去,在将数据读取回来。大家有什么好的办法。

python通过http传输文件及数据

一个检测系统,三台树莓派采集环境变量及拍照后将环境变量数据和照片发送至服务器,正常运行了半个多月后服务器忽然收不到数据了,调试后发现是因为树莓派无法正常发送照片,重新启动服务器上接收照片的程序后又正常了,不知道问题产生的原因是什么 以下是服务器上接收照片的程序 #--coding:utf8-- from BaseHTTPServer import BaseHTTPRequestHandler import mysql.connector import cgi class PostHandler(BaseHTTPRequestHandler): def do_POST(self): form = cgi.FieldStorage( fp=self.rfile, headers=self.headers, environ={'REQUEST_METHOD':'POST', 'CONTENT_TYPE':self.headers['Content-Type'], } ) self.send_response(200) self.end_headers() self.wfile.write('Client: %sn ' % str(self.client_address) ) self.wfile.write('User-agent: %sn' % str(self.headers['user-agent'])) self.wfile.write('Path: %sn'%self.path) self.wfile.write('Form data:n') for field in form.keys(): field_item = form[field] filename = field_item.filename filevalue = field_item.value filesize = len(filevalue)#文件大小(字节) print len(filevalue) with open(filename.decode('utf-8'),'wb') as f: f.write(filevalue) return if __name__=='__main__': from BaseHTTPServer import HTTPServer sever = HTTPServer(('0.0.0.0',8002),PostHandler) print 'Starting server, use <Ctrl-C> to stop' sever.serve_forever() 以下是树莓派发送图片的程序,树莓派上运行的主程序通过调用postpic来发送照片 #coding=utf-8 import requests #hello函数用于测试模块调用是否成功 def pichello(): print "hello pic" def postpic(path): url='http://......:8002' files={'file':open(path,'rb')} try: r=requests.post(url,files=files) return 1 except: return 0 if __name__=="__main__": path = '/home/pi/LowVoltageRoom/PythonHTTPPic/test.jpg' postpic(path) 我猜想可能是多台设备同时发送照片导致数据阻塞引起的,我尝试在一台设备发送照片未结束时另一台同时发送,结果都成功了。现在系统运行正常,不知道什么时候会再出问题,求各路大神帮忙分析一下问题出现的原因

TCP传输,客户的程序一直不停的建立socket连接,不断开,最终导致我的服务端崩溃

做了一个服务端程序,提供给客户数据,用的是TCP传输,结果客户的程序一直不停的建立socket连接,不断开,最终端口耗尽了,导致我的服务端崩溃,服务端如何限制客户的这种做法

QT:文件传输长时间没反应

选择文件点击发送以后,进度条长时间不动 请问是哪里出问题 ![图片说明](https://img-ask.csdn.net/upload/202005/13/1589356251_269947.jpg) ![图片说明](https://img-ask.csdn.net/upload/202005/13/1589356315_272742.jpg) ``` widgt.cpp void Widget::hasPendingFile(QString userName,QString serverAddress, //接收文件 QString clientAddress,QString fileName) { QString ipAddress = getIP(); if(ipAddress == clientAddress) { int btn = QMessageBox::information(this,tr("接受文件"), tr("来自%1(%2)的文件:%3,是否接收?") .arg(userName).arg(serverAddress).arg(fileName), QMessageBox::Yes,QMessageBox::No); if(btn == QMessageBox::Yes) { QString name = QFileDialog::getSaveFileName(0,tr("保存文件"),fileName); if(!name.isEmpty()) { TcpClient *client = new TcpClient(this); client->setFileName(name); client->setHostAddress(QHostAddress(serverAddress)); client->show(); } } else{ sendMessage(Refuse,serverAddress); } } } void Widget::on_sendfile_clicked()//发送文件按钮槽函数 { if(ui->tableWidget->selectedItems().isEmpty()) { QMessageBox::warning(0,tr("选择用户"),tr("请先从用户列表选择要传送的用户!"),QMessageBox::Ok); return; } server->show(); server->initServer(); } tcpclient.cpp void TcpClient::readMessage() { QDataStream in(tcpClient); in.setVersion(QDataStream::Qt_4_6); float useTime = time.elapsed(); if(bytesReceived <= sizeof(qint64)*2){ if((tcpClient->bytesAvailable() >= sizeof(qint64)*2) && (fileNameSize == 0)){ in>>TotalBytes>>fileNameSize; bytesReceived += sizeof(qint64)*2; } if((tcpClient->bytesAvailable() >= fileNameSize) && (fileNameSize != 0)){ in>>fileName; bytesReceived +=fileNameSize; if(!localFile->open(QFile::WriteOnly)){ QMessageBox::warning(this,tr("应用程序"),tr("无法读取文件 %1:\n%2.").arg(fileName).arg(localFile->errorString())); return; } }else{ return; } } if(bytesReceived < TotalBytes){ bytesReceived += tcpClient->bytesAvailable(); inBlock = tcpClient->readAll(); localFile->write(inBlock); inBlock.resize(0); } ui->progressBar->setMaximum(TotalBytes); ui->progressBar->setValue(bytesReceived); qDebug()<<bytesReceived<<"received"<<TotalBytes; double speed = bytesReceived / useTime; ui->tcpClientStatusLabel->setText(tr("已接收 %1MB (%2MB/s) \n共%3MB 已用时:%4秒\n估计剩余时间:%5秒") .arg(bytesReceived / (1024*1024))//已接收 .arg(speed*1000/(1024*1024),0,'f',2)//速度 .arg(TotalBytes / (1024 * 1024))//总大小 .arg(useTime/1000,0,'f',0)//用时 .arg(TotalBytes/speed/1000 - useTime/1000,0,'f',0));//剩余时间 if(bytesReceived == TotalBytes) { tcpClient->close(); ui->tcpClientStatusLabel->setText(tr("接收文件 %1 完毕").arg(fileName)); localFile->close(); //接收完文件后,一定要关闭,不然可能出问题 } } tcpserver.cpp void TcpServer::sendMessage() //开始发送数据 { ui->serverSendBtn->setEnabled(false); clientConnection = tcpServer->nextPendingConnection(); connect(clientConnection,SIGNAL(bytesWritten(qint64)),SLOT(updateClientProgress(qint64))); ui->serverStatusLabel->setText(tr("开始传送文件 %1 !").arg(theFileName)); localFile = new QFile(fileName); if(!localFile->open((QFile::ReadOnly))){//以只读方式打开 QMessageBox::warning(this,tr("应用程序"),tr("无法读取文件 %1:\n%2").arg(fileName).arg(localFile->errorString())); return; } TotalBytes = localFile->size(); QDataStream sendOut(&outBlock,QIODevice::WriteOnly); sendOut.setVersion(QDataStream::Qt_4_6); time.start(); //开始计时 QString currentFile = fileName.right(fileName.size() - fileName.lastIndexOf('/')-1); sendOut<<qint64(0)<<qint64(0)<<currentFile; TotalBytes += outBlock.size(); sendOut.device()->seek(0); sendOut<<TotalBytes<<qint64((outBlock.size()-sizeof(qint64)*2)); bytesToWrite = TotalBytes - clientConnection->write(outBlock); qDebug()<<currentFile<<TotalBytes; outBlock.resize(0); } void TcpServer::updateClientProgress(qint64 numBytes)//更新进度条 { bytesWritten += (int)numBytes; if(bytesToWrite > 0){ outBlock = localFile->read(qMin(bytesToWrite,loadSize)); bytesToWrite -= (int)clientConnection->write(outBlock); outBlock.resize(0); } else{ localFile->close(); } ui->progressBar->setMaximum(TotalBytes); ui->progressBar->setValue(bytesWritten); float useTime = time.elapsed(); double speed = bytesWritten / useTime; ui->serverStatusLabel->setText(tr("已发送 %1MB (%2MB/s) \n共%3MB 已用时:%4秒\n估计剩余时间:%5秒") .arg(bytesWritten / (1024*1024))//已发送 .arg(speed*1000/(1024*1024),0,'f',2)//速度 .arg(TotalBytes / (1024 * 1024))//总大小 .arg(useTime/1000,0,'f',0)//用时 .arg(TotalBytes/speed/1000 - useTime/1000,0,'f',0));//剩余时间 //num.sprintf("%.1f KB/s", (bytesWritten*1000) / (1024.0*time.elapsed())); if(bytesWritten == TotalBytes) ui->serverStatusLabel->setText(tr("传送文件 %1 成功").arg(theFileName)); } void TcpServer::on_serverOpenBtn_clicked() //打开 { fileName = QFileDialog::getOpenFileName(this); if(!fileName.isEmpty()) { theFileName = fileName.right(fileName.size() - fileName.lastIndexOf('/')-1); ui->serverStatusLabel->setText(tr("要传送的文件为:%1 ").arg(theFileName)); ui->serverSendBtn->setEnabled(true); ui->serverOpenBtn->setEnabled(false); } } void TcpServer::refused() //被对方拒绝 { tcpServer->close(); ui->serverStatusLabel->setText(tr("对方拒绝接收!!!")); } void TcpServer::on_serverSendBtn_clicked() //发送 { if(!tcpServer->listen(QHostAddress::Any,tcpPort))//开始监听 { qDebug() << tcpServer->errorString(); close(); return; } ui->serverStatusLabel->setText(tr("等待对方接收... ...")); emit sendFileName(theFileName); } void TcpServer::on_serverCloseBtn_clicked()//退出 { if(tcpServer->isListening()) { tcpServer->close(); clientConnection->abort(); } this->close(); } void TcpServer::initServer()//初始化 { loadSize = 4*1024; TotalBytes = 0; bytesWritten = 0; bytesToWrite = 0; ui->serverStatusLabel->setText(tr("请选择要传送的文件")); ui->progressBar->reset(); ui->serverOpenBtn->setEnabled(true); ui->serverSendBtn->setEnabled(false); tcpServer->close(); } ```

用VLC播放RTP传输过来H264的问题,不使用打开sdp文件的方式

用VLC播放RTP/UDP/TCP传输过来H264的问题,不使用打开sdp文件的方式

VS上编写C语言套接字编程

![图片说明](https://img-ask.csdn.net/upload/201803/14/1521027677_475697.png)VS2017上<netinet/in.h>源文件为什么打不开???求教大佬们

QT开发实战精解5.3局域网聊天系统 文件传输时一直处于等待的状态

完全按照书本例子写的码,问题是传输文件时一直处于等待状态,无论是本机发往本机还是不同主机之间都不成功。不明白是哪里出问题,求大神解答!代码如下,如果觉得看起来麻烦可以问我要工程文件调试,感激不尽! ``` widget.cpp: #include "widget.h" #include "ui_widget.h" #include <QUdpSocket> #include <QHostInfo> #include <QMessageBox> #include <QScrollBar> #include <QDateTime> #include <QNetworkInterface> #include <QProcess> #include "tcpserver.h" #include "tcpclient.h" #include <QFileDialog> Widget::Widget(QWidget *parent) : QWidget(parent), ui(new Ui::Widget) { ui->setupUi(this); udpSocket = new QUdpSocket(this); port = 45454; udpSocket->bind(port, QUdpSocket::ShareAddress | QUdpSocket::ReuseAddressHint); connect(udpSocket, SIGNAL(readyRead()), this, SLOT(processPendingDatagrams())); sendMessage(NewParticipant); server = new TcpServer(this); connect(server, SIGNAL(sendFileName(QString)), this, SLOT(getFileName(QString))); } Widget::~Widget() { delete ui; } // 使用UDP广播发送信息 void Widget::sendMessage(MessageType type, QString serverAddress) { QByteArray data; QDataStream out(&data, QIODevice::WriteOnly); QString localHostName = QHostInfo::localHostName(); QString address = getIP(); out << type << getUserName() << localHostName; switch(type) { case Message : if (ui->messageTextEdit->toPlainText() == "") { QMessageBox::warning(0,tr("警告"),tr("发送内容不能为空"),QMessageBox::Ok); return; } out << address << getMessage(); ui->messageBrowser->verticalScrollBar() ->setValue(ui->messageBrowser->verticalScrollBar()->maximum()); break; case NewParticipant : out << address; break; case ParticipantLeft : break; case FileName : { int row = ui->userTableWidget->currentRow(); QString clientAddress = ui->userTableWidget->item(row, 2)->text(); out << address << clientAddress << fileName; break; } case Refuse : out << serverAddress; break; } udpSocket->writeDatagram(data,data.length(),QHostAddress::Broadcast, port); } // 接收UDP信息 void Widget::processPendingDatagrams() { while(udpSocket->hasPendingDatagrams()) { QByteArray datagram; datagram.resize(udpSocket->pendingDatagramSize()); udpSocket->readDatagram(datagram.data(), datagram.size()); QDataStream in(&datagram, QIODevice::ReadOnly); int messageType; in >> messageType; QString userName,localHostName,ipAddress,message; QString time = QDateTime::currentDateTime() .toString("yyyy-MM-dd hh:mm:ss"); switch(messageType) { case Message: in >> userName >> localHostName >> ipAddress >> message; ui->messageBrowser->setTextColor(Qt::blue); ui->messageBrowser->setCurrentFont(QFont("Times New Roman",12)); ui->messageBrowser->append("[ " +userName+" ] "+ time); ui->messageBrowser->append(message); break; case NewParticipant: in >>userName >>localHostName >>ipAddress; newParticipant(userName,localHostName,ipAddress); break; case ParticipantLeft: in >>userName >>localHostName; participantLeft(userName,localHostName,time); break; case FileName: { in >> userName >> localHostName >> ipAddress; QString clientAddress, fileName; in >> clientAddress >> fileName; hasPendingFile(userName, ipAddress, clientAddress, fileName); break; } case Refuse: { in >> userName >> localHostName; QString serverAddress; in >> serverAddress; QString ipAddress = getIP(); if(ipAddress == serverAddress) { server->refused(); } break; } } } } // 处理新用户加入 void Widget::newParticipant(QString userName, QString localHostName, QString ipAddress) { bool isEmpty = ui->userTableWidget->findItems(localHostName, Qt::MatchExactly).isEmpty(); if (isEmpty) { QTableWidgetItem *user = new QTableWidgetItem(userName); QTableWidgetItem *host = new QTableWidgetItem(localHostName); QTableWidgetItem *ip = new QTableWidgetItem(ipAddress); ui->userTableWidget->insertRow(0); ui->userTableWidget->setItem(0,0,user); ui->userTableWidget->setItem(0,1,host); ui->userTableWidget->setItem(0,2,ip); ui->messageBrowser->setTextColor(Qt::gray); ui->messageBrowser->setCurrentFont(QFont("Times New Roman",10)); ui->messageBrowser->append(tr("%1 在线!").arg(userName)); ui->userNumLabel->setText(tr("在线人数:%1").arg(ui->userTableWidget->rowCount())); sendMessage(NewParticipant); } } // 处理用户离开 void Widget::participantLeft(QString userName, QString localHostName, QString time) { int rowNum = ui->userTableWidget->findItems(localHostName, Qt::MatchExactly).first()->row(); ui->userTableWidget->removeRow(rowNum); ui->messageBrowser->setTextColor(Qt::gray); ui->messageBrowser->setCurrentFont(QFont("Times New Roman", 10)); ui->messageBrowser->append(tr("%1 于 %2 离开!").arg(userName).arg(time)); ui->userNumLabel->setText(tr("在线人数:%1").arg(ui->userTableWidget->rowCount())); } // 获取ip地址 QString Widget::getIP() { QList<QHostAddress> list = QNetworkInterface::allAddresses(); foreach (QHostAddress address, list) { if(address.protocol() == QAbstractSocket::IPv4Protocol) return address.toString(); } return 0; } // 获取用户名 QString Widget::getUserName() { QStringList envVariables; envVariables << "USERNAME.*" << "USER.*" << "USERDOMAIN.*" << "HOSTNAME.*" << "DOMAINNAME.*"; QStringList environment = QProcess::systemEnvironment(); foreach (QString string, envVariables) { int index = environment.indexOf(QRegExp(string)); if (index != -1) { QStringList stringList = environment.at(index).split('='); if (stringList.size() == 2) { return stringList.at(1); break; } } } return "unknown"; } // 获得要发送的消息 QString Widget::getMessage() { QString msg = ui->messageTextEdit->toHtml(); ui->messageTextEdit->clear(); ui->messageTextEdit->setFocus(); return msg; } // 发送消息 void Widget::on_sendButton_clicked() { sendMessage(Message); } // 获取要发送的文件名 void Widget::getFileName(QString name) { fileName = name; sendMessage(FileName); } // 传输文件按钮 void Widget::on_sendToolBtn_clicked() { if(ui->userTableWidget->selectedItems().isEmpty()) { QMessageBox::warning(0, tr("选择用户"), tr("请先从用户列表选择要传送的用户!"), QMessageBox::Ok); return; } server->show(); server->initServer(); } // 是否接收文件 void Widget::hasPendingFile(QString userName, QString serverAddress, QString clientAddress, QString fileName) { QString ipAddress = getIP(); if(ipAddress == clientAddress) { int btn = QMessageBox::information(this,tr("接受文件"), tr("来自%1(%2)的文件:%3,是否接收?") .arg(userName).arg(serverAddress).arg(fileName), QMessageBox::Yes,QMessageBox::No); if (btn == QMessageBox::Yes) { QString name = QFileDialog::getSaveFileName(0,tr("保存文件"),fileName); if(!name.isEmpty()) { TcpClient *client = new TcpClient(this); client->setFileName(name); client->setHostAddress(QHostAddress(serverAddress)); client->show(); } } else { sendMessage(Refuse, serverAddress); } } } tcpserver.cpp: #include "tcpserver.h" #include "ui_tcpserver.h" #include <QFile> #include <QTcpServer> #include <QTcpSocket> #include <QMessageBox> #include <QFileDialog> #include <QDebug> TcpServer::TcpServer(QWidget *parent) : QDialog(parent), ui(new Ui::TcpServer) { ui->setupUi(this); setFixedSize(350,180); tcpPort = 6666; tcpServer = new QTcpServer(this); connect(tcpServer, SIGNAL(newConnection()), this, SLOT(sendMessage())); initServer(); } TcpServer::~TcpServer() { delete ui; } // 初始化 void TcpServer::initServer() { payloadSize = 64*1024; TotalBytes = 0; bytesWritten = 0; bytesToWrite = 0; ui->serverStatusLabel->setText(tr("请选择要传送的文件")); ui->progressBar->reset(); ui->serverOpenBtn->setEnabled(true); ui->serverSendBtn->setEnabled(false); tcpServer->close(); } // 开始发送数据 void TcpServer::sendMessage() { ui->serverSendBtn->setEnabled(false); clientConnection = tcpServer->nextPendingConnection(); connect(clientConnection, SIGNAL(bytesWritten(qint64)), this, SLOT(updateClientProgress(qint64))); ui->serverStatusLabel->setText(tr("开始传送文件 %1 !").arg(theFileName)); localFile = new QFile(fileName); if(!localFile->open((QFile::ReadOnly))){ QMessageBox::warning(this, tr("应用程序"), tr("无法读取文件 %1:\n%2") .arg(fileName).arg(localFile->errorString())); return; } TotalBytes = localFile->size(); QDataStream sendOut(&outBlock, QIODevice::WriteOnly); sendOut.setVersion(QDataStream::Qt_4_7); time.start(); // 开始计时 QString currentFile = fileName.right(fileName.size() - fileName.lastIndexOf('/')-1); sendOut << qint64(0) << qint64(0) << currentFile; TotalBytes += outBlock.size(); sendOut.device()->seek(0); sendOut << TotalBytes << qint64((outBlock.size() - sizeof(qint64)*2)); bytesToWrite = TotalBytes - clientConnection->write(outBlock); outBlock.resize(0); } // 更新进度条 void TcpServer::updateClientProgress(qint64 numBytes) { qApp->processEvents(); bytesWritten += (int)numBytes; if (bytesToWrite > 0) { outBlock = localFile->read(qMin(bytesToWrite, payloadSize)); bytesToWrite -= (int)clientConnection->write(outBlock); outBlock.resize(0); } else { localFile->close(); } ui->progressBar->setMaximum(TotalBytes); ui->progressBar->setValue(bytesWritten); float useTime = time.elapsed(); double speed = bytesWritten / useTime; ui->serverStatusLabel->setText(tr("已发送 %1MB (%2MB/s) " "\n共%3MB 已用时:%4秒\n估计剩余时间:%5秒") .arg(bytesWritten / (1024*1024)) .arg(speed*1000 / (1024*1024), 0, 'f', 2) .arg(TotalBytes / (1024 * 1024)) .arg(useTime/1000, 0, 'f', 0) .arg(TotalBytes/speed/1000 - useTime/1000, 0, 'f', 0)); if(bytesWritten == TotalBytes) { localFile->close(); tcpServer->close(); ui->serverStatusLabel->setText(tr("传送文件 %1 成功").arg(theFileName)); } } // 打开按钮 void TcpServer::on_serverOpenBtn_clicked() { fileName = QFileDialog::getOpenFileName(this); if(!fileName.isEmpty()) { theFileName = fileName.right(fileName.size() - fileName.lastIndexOf('/')-1); ui->serverStatusLabel->setText(tr("要传送的文件为:%1 ").arg(theFileName)); ui->serverSendBtn->setEnabled(true); ui->serverOpenBtn->setEnabled(false); } } // 发送按钮 void TcpServer::on_serverSendBtn_clicked() { if(!tcpServer->listen(QHostAddress::Any,tcpPort))//开始监听 { qDebug() << tcpServer->errorString(); close(); return; } ui->serverStatusLabel->setText(tr("等待对方接收... ...")); emit sendFileName(theFileName); } // 关闭按钮 void TcpServer::on_serverCloseBtn_clicked() { if(tcpServer->isListening()) { tcpServer->close(); if (localFile->isOpen()) localFile->close(); clientConnection->abort(); } close(); } // 被对方拒绝 void TcpServer::refused() { tcpServer->close(); ui->serverStatusLabel->setText(tr("对方拒绝接收!!!")); } // 关闭事件 void TcpServer::closeEvent(QCloseEvent *) { on_serverCloseBtn_clicked(); } tcpclient.cpp #include "tcpclient.h" #include "ui_tcpclient.h" #include <QTcpSocket> #include <QDebug> #include <QMessageBox> TcpClient::TcpClient(QWidget *parent) : QDialog(parent), ui(new Ui::TcpClient) { ui->setupUi(this); setFixedSize(350,180); TotalBytes = 0; bytesReceived = 0; fileNameSize = 0; tcpClient = new QTcpSocket(this); tcpPort = 6666; connect(tcpClient, SIGNAL(readyRead()), this, SLOT(readMessage())); connect(tcpClient, SIGNAL(error(QAbstractSocket::SocketError)), this, SLOT(displayError(QAbstractSocket::SocketError))); } TcpClient::~TcpClient() { delete ui; } // 设置文件名 void TcpClient::setFileName(QString fileName) { localFile = new QFile(fileName); } // 设置地址 void TcpClient::setHostAddress(QHostAddress address) { hostAddress = address; newConnect(); } // 创建新连接 void TcpClient::newConnect() { blockSize = 0; tcpClient->abort(); tcpClient->connectToHost(hostAddress, tcpPort); time.start(); } // 读取数据 void TcpClient::readMessage() { QDataStream in(tcpClient); in.setVersion(QDataStream::Qt_4_7); float useTime = time.elapsed(); if (bytesReceived <= sizeof(qint64)*2) { if ((tcpClient->bytesAvailable() >= sizeof(qint64)*2) && (fileNameSize == 0)) { in>>TotalBytes>>fileNameSize; bytesReceived += sizeof(qint64)*2; } if((tcpClient->bytesAvailable() >= fileNameSize) && (fileNameSize != 0)){ in>>fileName; bytesReceived +=fileNameSize; if(!localFile->open(QFile::WriteOnly)){ QMessageBox::warning(this,tr("应用程序"),tr("无法读取文件 %1:\n%2.") .arg(fileName).arg(localFile->errorString())); return; } } else { return; } } if (bytesReceived < TotalBytes) { bytesReceived += tcpClient->bytesAvailable(); inBlock = tcpClient->readAll(); localFile->write(inBlock); inBlock.resize(0); } ui->progressBar->setMaximum(TotalBytes); ui->progressBar->setValue(bytesReceived); double speed = bytesReceived / useTime; ui->tcpClientStatusLabel->setText(tr("已接收 %1MB (%2MB/s) " "\n共%3MB 已用时:%4秒\n估计剩余时间:%5秒") .arg(bytesReceived / (1024*1024)) .arg(speed*1000/(1024*1024),0,'f',2) .arg(TotalBytes / (1024 * 1024)) .arg(useTime/1000,0,'f',0) .arg(TotalBytes/speed/1000 - useTime/1000,0,'f',0)); if(bytesReceived == TotalBytes) { localFile->close(); tcpClient->close(); ui->tcpClientStatusLabel->setText(tr("接收文件 %1 完毕") .arg(fileName)); } } // 错误处理 void TcpClient::displayError(QAbstractSocket::SocketError socketError) { switch(socketError) { case QAbstractSocket::RemoteHostClosedError : break; default : qDebug() << tcpClient->errorString(); } } // 取消按钮 void TcpClient::on_tcpClientCancleBtn_clicked() { tcpClient->abort(); if (localFile->isOpen()) localFile->close(); } // 关闭按钮 void TcpClient::on_tcpClientCloseBtn_clicked() { tcpClient->abort(); if (localFile->isOpen()) localFile->close(); close(); } // 关闭事件 void TcpClient::closeEvent(QCloseEvent *) { on_tcpClientCloseBtn_clicked(); } ``` ![图片说明](https://img-ask.csdn.net/upload/202005/14/1589465615_112914.jpg)

大学四年自学走来,这些私藏的实用工具/学习网站我贡献出来了

大学四年,看课本是不可能一直看课本的了,对于学习,特别是自学,善于搜索网上的一些资源来辅助,还是非常有必要的,下面我就把这几年私藏的各种资源,网站贡献出来给你们。主要有:电子书搜索、实用工具、在线视频学习网站、非视频学习网站、软件下载、面试/求职必备网站。 注意:文中提到的所有资源,文末我都给你整理好了,你们只管拿去,如果觉得不错,转发、分享就是最大的支持了。 一、电子书搜索 对于大部分程序员...

在中国程序员是青春饭吗?

今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...

Java基础知识面试题(2020最新版)

文章目录Java概述何为编程什么是Javajdk1.5之后的三大版本JVM、JRE和JDK的关系什么是跨平台性?原理是什么Java语言有哪些特点什么是字节码?采用字节码的最大好处是什么什么是Java程序的主类?应用程序和小程序的主类有何不同?Java应用程序与小程序之间有那些差别?Java和C++的区别Oracle JDK 和 OpenJDK 的对比基础语法数据类型Java有哪些数据类型switc...

我以为我学懂了数据结构,直到看了这个导图才发现,我错了

数据结构与算法思维导图

String s = new String(" a ") 到底产生几个对象?

老生常谈的一个梗,到2020了还在争论,你们一天天的,哎哎哎,我不是针对你一个,我是说在座的各位都是人才! 上图红色的这3个箭头,对于通过new产生一个字符串(”宜春”)时,会先去常量池中查找是否已经有了”宜春”对象,如果没有则在常量池中创建一个此字符串对象,然后堆中再创建一个常量池中此”宜春”对象的拷贝对象。 也就是说准确答案是产生了一个或两个对象,如果常量池中原来没有 ”宜春” ,就是两个。...

技术大佬:我去,你写的 switch 语句也太老土了吧

昨天早上通过远程的方式 review 了两名新来同事的代码,大部分代码都写得很漂亮,严谨的同时注释也很到位,这令我非常满意。但当我看到他们当中有一个人写的 switch 语句时,还是忍不住破口大骂:“我擦,小王,你丫写的 switch 语句也太老土了吧!” 来看看小王写的代码吧,看完不要骂我装逼啊。 private static String createPlayer(PlayerTypes p...

Linux面试题(2020最新版)

文章目录Linux 概述什么是LinuxUnix和Linux有什么区别?什么是 Linux 内核?Linux的基本组件是什么?Linux 的体系结构BASH和DOS之间的基本区别是什么?Linux 开机启动过程?Linux系统缺省的运行级别?Linux 使用的进程间通信方式?Linux 有哪些系统日志文件?Linux系统安装多个桌面环境有帮助吗?什么是交换空间?什么是root帐户什么是LILO?什...

Linux命令学习神器!命令看不懂直接给你解释!

大家都知道,Linux 系统有非常多的命令,而且每个命令又有非常多的用法,想要全部记住所有命令的所有用法,恐怕是一件不可能完成的任务。 一般情况下,我们学习一个命令时,要么直接百度去搜索它的用法,要么就直接用 man 命令去查看守冗长的帮助手册。这两个都可以实现我们的目标,但有没有更简便的方式呢? 答案是必须有的!今天给大家推荐一款有趣而实用学习神器 — kmdr,让你解锁 Linux 学习新姿势...

和黑客斗争的 6 天!

互联网公司工作,很难避免不和黑客们打交道,我呆过的两家互联网公司,几乎每月每天每分钟都有黑客在公司网站上扫描。有的是寻找 Sql 注入的缺口,有的是寻找线上服务器可能存在的漏洞,大部分都...

史上最全的 python 基础知识汇总篇,没有比这再全面的了,建议收藏

网友们有福了,小编终于把基础篇的内容全部涉略了一遍,这是一篇关于基础知识的汇总的文章,请朋友们收下,不用客气,不过文章篇幅肯能会有点长,耐心阅读吧爬虫(七十)多进程multiproces...

讲一个程序员如何副业月赚三万的真实故事

loonggg读完需要3分钟速读仅需 1 分钟大家好,我是你们的校长。我之前讲过,这年头,只要肯动脑,肯行动,程序员凭借自己的技术,赚钱的方式还是有很多种的。仅仅靠在公司出卖自己的劳动时...

女程序员,为什么比男程序员少???

昨天看到一档综艺节目,讨论了两个话题:(1)中国学生的数学成绩,平均下来看,会比国外好?为什么?(2)男生的数学成绩,平均下来看,会比女生好?为什么?同时,我又联想到了一个技术圈经常讨...

85后蒋凡:28岁实现财务自由、34岁成为阿里万亿电商帝国双掌门,他的人生底层逻辑是什么?...

蒋凡是何许人也? 2017年12月27日,在入职4年时间里,蒋凡开挂般坐上了淘宝总裁位置。 为此,时任阿里CEO张勇在任命书中力赞: 蒋凡加入阿里,始终保持创业者的冲劲,有敏锐的...

总结了 150 余个神奇网站,你不来瞅瞅吗?

原博客再更新,可能就没了,之后将持续更新本篇博客。

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

MySQL数据库面试题(2020最新版)

文章目录数据库基础知识为什么要使用数据库什么是SQL?什么是MySQL?数据库三大范式是什么mysql有关权限的表都有哪几个MySQL的binlog有有几种录入格式?分别有什么区别?数据类型mysql有哪些数据类型引擎MySQL存储引擎MyISAM与InnoDB区别MyISAM索引与InnoDB索引的区别?InnoDB引擎的4大特性存储引擎选择索引什么是索引?索引有哪些优缺点?索引使用场景(重点)...

新一代神器STM32CubeMonitor介绍、下载、安装和使用教程

关注、星标公众号,不错过精彩内容作者:黄工公众号:strongerHuang最近ST官网悄悄新上线了一款比较强大的工具:STM32CubeMonitor V1.0.0。经过我研究和使用之...

如果你是老板,你会不会踢了这样的员工?

有个好朋友ZS,是技术总监,昨天问我:“有一个老下属,跟了我很多年,做事勤勤恳恳,主动性也很好。但随着公司的发展,他的进步速度,跟不上团队的步伐了,有点...

我入职阿里后,才知道原来简历这么写

私下里,有不少读者问我:“二哥,如何才能写出一份专业的技术简历呢?我总感觉自己写的简历太烂了,所以投了无数份,都石沉大海了。”说实话,我自己好多年没有写过简历了,但我认识的一个同行,他在阿里,给我说了一些他当年写简历的方法论,我感觉太牛逼了,实在是忍不住,就分享了出来,希望能够帮助到你。 01、简历的本质 作为简历的撰写者,你必须要搞清楚一点,简历的本质是什么,它就是为了来销售你的价值主张的。往深...

大学一路走来,学习互联网全靠这几个网站,最终拿下了一把offer

大佬原来都是这样炼成的

离职半年了,老东家又发 offer,回不回?

有小伙伴问松哥这个问题,他在上海某公司,在离职了几个月后,前公司的领导联系到他,希望他能够返聘回去,他很纠结要不要回去? 俗话说好马不吃回头草,但是这个小伙伴既然感到纠结了,我觉得至少说明了两个问题:1.曾经的公司还不错;2.现在的日子也不是很如意。否则应该就不会纠结了。 老实说,松哥之前也有过类似的经历,今天就来和小伙伴们聊聊回头草到底吃不吃。 首先一个基本观点,就是离职了也没必要和老东家弄的苦...

为什么你不想学习?只想玩?人是如何一步一步废掉的

不知道是不是只有我这样子,还是你们也有过类似的经历。 上学的时候总有很多光辉历史,学年名列前茅,或者单科目大佬,但是虽然慢慢地长大了,你开始懈怠了,开始废掉了。。。 什么?你说不知道具体的情况是怎么样的? 我来告诉你: 你常常潜意识里或者心理觉得,自己真正的生活或者奋斗还没有开始。总是幻想着自己还拥有大把时间,还有无限的可能,自己还能逆风翻盘,只不是自己还没开始罢了,自己以后肯定会变得特别厉害...

什么时候跳槽,为什么离职,你想好了么?

都是出来打工的,多为自己着想

为什么程序员做外包会被瞧不起?

二哥,有个事想询问下您的意见,您觉得应届生值得去外包吗?公司虽然挺大的,中xx,但待遇感觉挺低,马上要报到,挺纠结的。

当HR压你价,说你只值7K,你该怎么回答?

当HR压你价,说你只值7K时,你可以流畅地回答,记住,是流畅,不能犹豫。 礼貌地说:“7K是吗?了解了。嗯~其实我对贵司的面试官印象很好。只不过,现在我的手头上已经有一份11K的offer。来面试,主要也是自己对贵司挺有兴趣的,所以过来看看……”(未完) 这段话主要是陪HR互诈的同时,从公司兴趣,公司职员印象上,都给予对方正面的肯定,既能提升HR的好感度,又能让谈判气氛融洽,为后面的发挥留足空间。...

面试阿里p7,被按在地上摩擦,鬼知道我经历了什么?

面试阿里p7被问到的问题(当时我只知道第一个):@Conditional是做什么的?@Conditional多个条件是什么逻辑关系?条件判断在什么时候执...

你期望月薪4万,出门右拐,不送,这几个点,你也就是个初级的水平

先来看几个问题通过注解的方式注入依赖对象,介绍一下你知道的几种方式@Autowired和@Resource有何区别说一下@Autowired查找候选者的...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

立即提问
相关内容推荐