suzhe/net-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

use ggg

Browse Source
This commit is contained in:
suzhe 2023-12-05 19:19:22 +08:00
parent c544af38a4
commit d25b6f96b5
6 changed files with 219 additions and 118 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
cli.py Normal file
View File

@ -0,0 +1,24 @@
# 导入 socket、sys 模块
import socket
import sys
# 创建 socket 对象
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 获取本地主机名
host = socket.gethostname()
# 设置端口号
port = 9999
# 连接服务，指定主机和端口
s.connect((host, port))
# 接收小于 1024 字节的数据
tex = "this is test"
s.send(tex.encode('utf-8'))
msg = s.recv(1024)
s.close()
print (msg.decode('utf-8'))

127
client.c
View File

@ -1,47 +1,86 @@
#include "stdafx.h" #include "inclu.h"
#include <WINSOCK2.H>
#include <STDIO.H>
#pragma comment(lib,"ws2_32.lib")
/*readline函数实现*/
ssize_t readline(int fd, char *vptr, size_t maxlen)
int main(int argc, char* argv[])
{ {
WORD sockVersion = MAKEWORD(2,2); ssize_t n, rc;
WSADATA data; char c, *ptr;
if(WSAStartup(sockVersion, &data) != 0)
{ ptr = vptr;
return 0; for (n = 1; n < maxlen; n++) {
} if ( (rc = read(fd, &c,1)) == 1) {
*ptr++ = c;
SOCKET sclient = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP); if (c == '\n')
if(sclient == INVALID_SOCKET) break; /* newline is stored, like fgets() */
{ } else if (rc == 0) {
printf("invalid socket !"); *ptr = 0;
return 0; return(n - 1); /* EOF, n - 1 bytes were read */
} } else
return(-1); /* error, errno set by read() */
sockaddr_in serAddr; }
serAddr.sin_family = AF_INET;
serAddr.sin_port = htons(8888); *ptr = 0; /* null terminate like fgets() */
serAddr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); return(n);
if (connect(sclient, (sockaddr *)&serAddr, sizeof(serAddr)) == SOCKET_ERROR) }
{
printf("connect error !");
closesocket(sclient); int main(int argc , char ** argv)
return 0; {
} /*声明套接字和链接服务器地址*/
char * sendData = "你好，TCP服务端，我是客户端!\n"; int sockfd;
send(sclient, sendData, strlen(sendData), 0); struct sockaddr_in servaddr;
char recData[255]; /*判断是否为合法输入*/
int ret = recv(sclient, recData, 255, 0); if(argc != 2)
if(ret > 0) {
{ perror("usage:tcpcli <IPaddress>");
recData[ret] = 0x00; exit(1);
printf(recData); }//if
}
closesocket(sclient); /*(1) 创建套接字*/
WSACleanup(); if((sockfd = socket(AF_INET , SOCK_STREAM , 0)) == -1)
return 0; {
perror("socket error");
exit(1);
}//if
/*(2) 设置链接服务器地址结构*/
bzero(&servaddr , sizeof(servaddr));
servaddr.sin_family = AF_INET;
servaddr.sin_port = htons(PORT);
if(inet_pton(AF_INET , argv[1] , &servaddr.sin_addr) < 0)
{
printf("inet_pton error for %s\n",argv[1]);
exit(1);
}//if
/*(3) 发送链接服务器请求*/
if( connect(sockfd , (struct sockaddr *)&servaddr , sizeof(servaddr)) < 0)
{
perror("connect error");
exit(1);
}//if
/*(4) 消息处理*/
char sendline[MAX_LINE] , recvline[MAX_LINE];
while(fgets(sendline , MAX_LINE , stdin) != NULL)
{
write(sockfd , sendline , strlen(sendline));
if(readline(sockfd , recvline , MAX_LINE) == 0)
{
perror("server terminated prematurely");
exit(1);
}//if
if(fputs(recvline , stdout) == EOF)
{
perror("fputs error");
exit(1);
}//if
}//while
/*(5) 关闭套接字*/
close(sockfd);
} }

16
inclu.h Normal file
View File

@ -0,0 +1,16 @@
#include <stdio.h>
//#include <stdlib.h>
//#include <string.h>
#include <sys/socket.h>
//#include <sys/types.h>
//#include <unistd.h>
//#include <errno.h>
//#include <netinet/in.h>
//#include <netdb.h>
//#include <arpa/inet.h>
//
//const int MAX_LINE = 2048;
const int PORT = 6000;
const int BACKLOG = 10;
const int LISTENQ = 6666;
const int MAX_CONNECT = 20;

25
ser.py Normal file
View File

@ -0,0 +1,25 @@
# 导入 socket、sys 模块
import socket
import sys
# 创建 socket 对象
serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 获取本地主机名
host = socket.gethostname()
port = 9999
# 绑定端口号
serversocket.bind((host, port))
# 设置最大连接数，超过后排队
serversocket.listen(5)
while True:
clientsocket,addr = serversocket.accept()
print("连接地址: %s" % str(addr))
masg='欢迎访问菜鸟教程！'+ "\r\n"
msg = clientsocket.recv(1024)
clientsocket.send(msg)
clientsocket.close()

144
server.c
View File

@ -1,75 +1,73 @@
#include "stdafx.h" #include "inclu.h"
#include <stdio.h>
#include <winsock2.h> int main(int argc , char **argv)
#pragma comment(lib,"ws2_32.lib")
int main(int argc, char* argv[])
{ {
//初始化WSA /*声明服务器地址和客户链接地址*/
WORD sockVersion = MAKEWORD(2,2); struct sockaddr_in servaddr , cliaddr;
WSADATA wsaData;
if(WSAStartup(sockVersion, &wsaData)!=0) /*声明服务器监听套接字和客户端链接套接字*/
{ int listenfd , connfd;
return 0; pid_t childpid;
}
/*声明缓冲区*/
//创建套接字 char buf[MAX_LINE];
SOCKET slisten = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if(slisten == INVALID_SOCKET) socklen_t clilen;
{
printf("socket error !"); /*(1) 初始化监听套接字listenfd*/
return 0; if((listenfd = socket(AF_INET , SOCK_STREAM , 0)) < 0)
} {
perror("socket error");
//绑定IP和端口 exit(1);
sockaddr_in sin; }//if
sin.sin_family = AF_INET;
sin.sin_port = htons(8888); /*(2) 设置服务器sockaddr_in结构*/
sin.sin_addr.S_un.S_addr = INADDR_ANY; bzero(&servaddr , sizeof(servaddr));
if(bind(slisten, (LPSOCKADDR)&sin, sizeof(sin)) == SOCKET_ERROR)
{ servaddr.sin_family = AF_INET;
printf("bind error !"); servaddr.sin_addr.s_addr = htonl(INADDR_ANY); //表明可接受任意IP地址
} servaddr.sin_port = htons(PORT);
//开始监听 /*(3) 绑定套接字和端口*/
if(listen(slisten, 5) == SOCKET_ERROR) if(bind(listenfd , (struct sockaddr*)&servaddr , sizeof(servaddr)) < 0)
{ {
printf("listen error !"); perror("bind error");
return 0; exit(1);
} }//if
//循环接收数据 /*(4) 监听客户请求*/
SOCKET sClient; if(listen(listenfd , LISTENQ) < 0)
sockaddr_in remoteAddr; {
int nAddrlen = sizeof(remoteAddr); perror("listen error");
char revData[255]; exit(1);
while (true) }//if
{
printf("等待连接...\n"); /*(5) 接受客户请求*/
sClient = accept(slisten, (SOCKADDR *)&remoteAddr, &nAddrlen); for( ; ; )
if(sClient == INVALID_SOCKET) {
{ clilen = sizeof(cliaddr);
printf("accept error !"); if((connfd = accept(listenfd , (struct sockaddr *)&cliaddr , &clilen)) < 0 )
continue; {
} perror("accept error");
printf("接受到一个连接：%s \r\n", inet_ntoa(remoteAddr.sin_addr)); exit(1);
}//if
//接收数据
int ret = recv(sClient, revData, 255, 0); //新建子进程单独处理链接
if(ret > 0) if((childpid = fork()) == 0)
{ {
revData[ret] = 0x00; close(listenfd);
printf(revData); //str_echo
} ssize_t n;
char buff[MAX_LINE];
//发送数据 while((n = read(connfd , buff , MAX_LINE)) > 0)
char * sendData = "你好，TCP客户端\n"; {
send(sClient, sendData, strlen(sendData), 0); write(connfd , buff , n);
closesocket(sClient); }
} exit(0);
}//if
closesocket(slisten); close(connfd);
WSACleanup(); }//for
return 0;
/*(6) 关闭监听套接字*/
close(listenfd);
} }

1
test1.c
View File

@ -1 +0,0 @@
#include <>