android socket 分包,：关于socket 分包的解决方法

系统管理员 2022-10-05 04:57 247阅读 0赞

C/C++ code// Server.cpp : create a console application, and include the sources in the project

// 1. open the \*.c in the Visual C++, then "rebuild all".

// 2. click "yes" to create a project workspace.

// 3. You need to -add the library 'ws2\_32.lib' to your project

// (Project -> Properties -> Linker -> Input -> Additional Dependencies)

// 4. recompile the source.

\#include "stdafx.h"

\#include

\#define DEFAULT\_PORT 5019

int find(char s\[\],char t\[\]);

void accept\_conn(void \*dummy);

SOCKET sock,new\_socket;

int main(int argc, char \*\*argv)\{

int addr\_len;

struct sockaddr\_in local, client\_addr;

WSADATA wsaData;

if (WSAStartup(0x202, &wsaData) == SOCKET\_ERROR)\{

// stderr: standard error are printed to the screen.

fprintf(stderr, "WSAStartup failed with error %d\\n", WSAGetLastError());

//WSACleanup function terminates use of the Windows Sockets DLL.

WSACleanup();

return -1;

// Fill in the address structure

local.sin\_family = AF\_INET;

local.sin\_addr.s\_addr = INADDR\_ANY;

local.sin\_port = htons(DEFAULT\_PORT);

sock = socket(AF\_INET,SOCK\_STREAM, 0); //TCp socket

if (sock == INVALID\_SOCKET)\{

fprintf(stderr, "socket() failed with error %d\\n", WSAGetLastError());

WSACleanup();

return -1;

if (bind(sock, (struct sockaddr \*)&local, sizeof(local)) == SOCKET\_ERROR)\{

fprintf(stderr, "bind() failed with error %d\\n", WSAGetLastError());

WSACleanup();

return -1;

//waiting for the connections

if (listen(sock, 5) == SOCKET\_ERROR)\{

fprintf(stderr, "listen() failed with error %d\\n", WSAGetLastError());

WSACleanup();

return -1;

printf("Waiting for the connections ........\\n");

int connecting=1;

while(connecting==1)

addr\_len = sizeof(client\_addr);

new\_socket=accept(sock, (struct sockaddr\*)&client\_addr, &addr\_len);

if (new\_socket == INVALID\_SOCKET)\{

fprintf(stderr, "accept() failed with error %d\\n", WSAGetLastError());

WSACleanup();

return -1;

printf("accepted connection from %s, port %d\\n",

inet\_ntoa(client\_addr.sin\_addr),

htons(client\_addr.sin\_port));

\_beginthread(accept\_conn, 0,NULL);

//Sleep(1000);

\}//while loop

\_endthread();

closesocket(sock);

WSACleanup();

int find(char s\[\],char t\[\] )

int j=0;

for (int i=0;s\[i\]!='\\0';i++)

if (t\[0\]==s\[i\])

while (t\[j\]!='\\0'&&s\[i+j\]!='\\0')

j++;

if (t\[j\]!=s\[i+j\])

break;

if (t\[j\]=='\\0')

return i;

return -1;

void accept\_conn(void \*dummy)

// doing something here

char szBuff\[100000\];

char szBuff2\[100000\];

char found\[100000\];

char buf\[100000\];

char \*p;

char \*temp;

int msg\_len;

int addr\_len;

bool again=true;

struct sockaddr\_in local, client\_addr;

SOCKET thread\_socket=new\_socket;

while(again)\{

msg\_len = recv(thread\_socket, szBuff, sizeof(szBuff), 0);

if (msg\_len == SOCKET\_ERROR)\{

fprintf(stderr, "recv() failed with error %d\\n", WSAGetLastError());

WSACleanup();

//return -1;

if (msg\_len == 0)\{

printf("Client closed connection\\n");

closesocket(thread\_socket);

//return -1;

//printf("Bytes Received: %d, message: %s from %s\\n", msg\_len, szBuff, inet\_ntoa(client\_addr.sin\_addr));

if(szBuff\[0\]=='b'&&szBuff\[1\]=='y'&&szBuff\[2\]=='e')\{

again=false;

szBuff2\[0\]='\\0';

found\[0\]='\\0';

buf\[0\]='\\0';

FILE \*fpin;

if((fpin=fopen("Course.txt","r"))==NULL)\{

printf("Cann't open this file!\\n");

while (!feof(fpin))\{

fgets(buf, 100000, fpin);

char data1\[100000\],data2\[100000\],data3\[100000\],data4\[100000\];

int session=0;

for (p = strtok(buf, "||"); p; p = strtok(NULL, "||")) \{

//printf("%s ", p);

if(session==0)\{

temp=p;

int index=0;

while(\*temp!='\\0')\{

data1\[index\]=\*temp++;

index++;\}

data1\[index\]='\\0';

\}else if(session==1)\{

temp=p;

int index=0;

while(\*temp!='\\0')\{

data2\[index\]=\*temp++;

index++;\}

data2\[index\]='\\0';

\}else if(session==2)\{

temp=p;

int index=0;

while(\*temp!='\\0')\{

data3\[index\]=\*temp++;

index++;\}

data3\[index\]='\\0';

\}else if(session==3)\{

temp=p;

int index=0;

while(\*temp!='\\0')\{

data4\[index\]=\*temp++;

index++;\}

data4\[index\]='\\0';

session++;

int intPOs1=find(data1,szBuff);

int intPOs2=find(data2,szBuff);

int intPOs3=find(data3,szBuff);

if(intPOs1>=0||intPOs2>=0||intPOs3>=0)\{

char courseCode\[10000\]="Course Code:";

char courseName\[10000\]="\\nCourse Name:";

char instructor\[10000\]="\\nCourse Instructor:";

char time\[10000\]="\\nTime Table:";

strcat(found,courseCode);

strcat(found,data1);

strcat(found,courseName);

strcat(found,data2);

strcat(found,instructor);

strcat(found,data3);

strcat(found,time);

strcat(found,data4);

printf("%s \\n", found);

strcat(szBuff2,found);

printf("this is szBuff2::::%s \\n", szBuff2);

found\[0\]='\\0';

fclose(fpin);

//printf("input character string:\\n");

//gets(szBuff2);

msg\_len = send(thread\_socket, szBuff2, sizeof(szBuff2), 0);

if (msg\_len == 0)\{

printf("Client closed connection\\n");

closesocket(thread\_socket);

//return -1;

closesocket(thread\_socket);

\_endthread();

android socket 分包,：关于socket 分包的解决方法

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 android socket 分包,：关于socket 分包的解决方法

相关 uniapp分包

相关 Android MultiDex分包变形记

相关 Java项目中的分包

相关小程序分包

相关异步SOCKET分包和组包的一种通用算法

相关小程序分包

相关 react ts wepack分包

相关 Android实现Udp socket通信且对数据进行分包和解析

相关 Taro——分包