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

系统管理员 2022-10-05 04:57 317阅读 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 分包的解决方法

发表评论取消回复

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

相关阅读

相关 webpack设置分包

相关 Socket组包和分包快速理解及相关示例

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

相关 uniapp分包

相关 Android MultiDex分包变形记

相关小程序分包

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

相关小程序分包

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

相关 Taro——分包