IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 系统运维 -> 在linux实现一个文件上传的服务器 -> 正文阅读

[系统运维]在linux实现一个文件上传的服务器

目的用来练习怎么使用socket来实现网络通信

整体流程:

Created with Rapha?l 2.3.0 server received connection? get data and save file yes no
Created with Rapha?l 2.3.0 client get file name send file name send file done? end yes no

server程序:

#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>

#define FILE_PATH "./file"
#define DIR_PATH  "./"

#define handle_error(msg) \
		do { perror(msg); } while(0)

#define BUF_SIZE	1024

void showPeerInfo(struct sockaddr_in* addr) {
	printf("peer addr: %s\n", inet_ntoa(addr->sin_addr));
}
int main (int argc, char *argv[])
{
	int sfs, rfs;
	ssize_t recvByte;
	char buffer[BUF_SIZE];
	short port = 4000;
	struct sockaddr_in addr, in_addr;
	socklen_t len;

	//1. Create Socket
	sfs = socket(AF_INET, SOCK_STREAM, 0);

	if (sfs < 0)
		handle_error("socket");

	memset(&addr, 0, sizeof(addr));

	addr.sin_family = AF_INET;
	addr.sin_port = htons(port);
	addr.sin_addr.s_addr = inet_addr("127.0.0.1");
	//addr.sin_addr.s_addr = htonl(INADDR_ANY);

	//2. Bind Address To Socket
	if (bind(sfs, (struct sockaddr*)&addr, sizeof(addr)) < 0)
		handle_error("bind");

	//3. Listen
	if (listen(sfs, 5) < 0)
		handle_error("listen");

	//4. Accept
	size_t count=0;	
	char fileName[20];
	strcpy(fileName, FILE_PATH);
	while (1) {
		rfs = accept(sfs, (struct sockaddr*)&in_addr, &len);
		//1. Get File Name From Client
		recvByte = recv(rfs, buffer, BUF_SIZE, 0);
		if (recvByte == 0) {
			sprintf(fileName, "%s_%ld.dat", FILE_PATH, count++);
		}
		else {
			strcpy(fileName, DIR_PATH);
			strcat(fileName, buffer);
		}
		FILE *file = fopen(fileName, "w+");
		if (file == NULL) {
				handle_error("file");
		}
		if (rfs < 0)
			handle_error("accept");
		//showPeerInfo(&in_addr);
		while (1) {
			recvByte = recv(rfs, buffer, BUF_SIZE, 0);		
			if ((recvByte==-1) ||(recvByte==0) )
				break;
			fwrite(buffer, sizeof(char), recvByte, file);
		}
		fclose(file);
		close(rfs);
	}
	return 0;
}

首先需要使用网络套接字(socket)需要创建一个socket,其实可以理解为一个文件描述符,然后将这个socket绑定到一个网络地址上(让client进行连接时使用的地址,使用的协议,使用的端口等),监听端口等待连接。

  1. socke()创建一个socket文件描述符
  2. bind()将一个地址,端口绑定到指定的socket
  3. listen()对指定的端口监听,看是否有client请求连接
    需要注意的是,在使用bind函数的时候,需要传入的地址的类型是:struct sockaddr类型的指针。
    struct sockaddr的类型如下:
    在这里插入图片描述
    _SOCKADDR_COMMON是一个宏,进行展开是:
    在这里插入图片描述
    需要关注的是第二个参数,是一个14个字符的数组,其中包含了地址和端口的信息,由于其混合了地址和端口,所以方便进行赋值,所以经常使用struct sockaddr_in类型,其定义如下:
    在这里插入图片描述
    其中in_port_t类型定义如下:
    在这里插入图片描述

其中struct in_addr类型的定义如下:
在这里插入图片描述
总的来说就是,struct sockaddr_in类型所占据的内部的大小和struck sockaddr所占的大小是相同的,也就是说两个可以直接就进行相互转换,但是struct sockaddr_in对其中的14字节大小的空间再次进行了划分,分为了2字节存储端口号,4字节存储32位的地址,剩的8字节清零。

字节序的注意:
多字节类型的数据在计算机中进行存储的时候,会有大端序和小端序,而在网络上进行数据传输的时候可能采取的顺序和计算机中的存储不相同,所以就需要进行转换,这就是htons函数的作用。

client程序

#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <string.h>

#define BUF_SIZE	1024

#define handle_error(msg) \
		do {perror(msg);} while(0)

void getFileName(char* dest, const char* sour) {
	size_t i, length = strlen(sour);
	i = length-1;
	while (sour[i--]!= '/');
	i += 2;
	strcpy(dest, sour+i);
}

int main(int argc, char* argv[])
{
	int rfs;
	size_t len;
	ssize_t sendByte;
	short port = 4000;
	char buffer[BUF_SIZE];
	struct sockaddr_in addr;
	FILE* fp;

	if (argc != 2) {
		printf("Usage: %s fileName\n", argv[0]);
		exit(-1);
	}

	//Check the exist of file
	if ((fp = fopen(argv[1], "r+")) == NULL) 
		handle_error("file exist");
	

	//1. Create Socket
	rfs = socket(AF_INET, SOCK_STREAM, 0);
	if (rfs == -1)
		handle_error("socket");

	memset(&addr, 0, sizeof(addr));
	addr.sin_family = AF_INET;
	addr.sin_port = htons(port);
	addr.sin_addr.s_addr = inet_addr("127.0.0.1");
	//2. Connect
	if (connect(rfs, (struct sockaddr*)&addr, sizeof(addr)) < 0)
	       handle_error("connect");	
	printf("Start your conversition\n");
	//Send The fileName
	getFileName(buffer, argv[1]);
	printf("fileName: %s\n", buffer);
	send(rfs, buffer, strlen(buffer), 0);
	//3. Send
	while (1) {
		len = fread(buffer, sizeof(char), BUF_SIZE, fp); 
		if (len == 0)
			break;
		send(rfs, buffer, len, 0);
	}
	
	fclose(fp);
	close(rfs);

	return 0;
}

首先创建一个socket用来标识需要连接的类型(IPV4,IPV6等,SOCK_STRAM, SOCK_DATAGRAM等),然后建立连接,当然在建立连接的时候需要知道server的IP地址,以及连接的端口号,同样使用struck sockaddr类型来表示,当连接服务器成功之后就可以使用send和recv来和server进行数据的传输了。

  1. 使用socket()创建一个socket描述符
  2. 使用connect()将指定的socket和server的地址,端口号进行关联
  3. 使用send()和recv()来和server进行通信

效果展示:
在这里插入图片描述

在这里插入图片描述
结果就是会在server程序存在的目录下,保存client发送的同名文件
在这里插入图片描述

  系统运维 最新文章
配置小型公司网络WLAN基本业务(AC通过三层
如何在交付运维过程中建立风险底线意识,提
快速传输大文件,怎么通过网络传大文件给对
从游戏服务端角度分析移动同步(状态同步)
MySQL使用MyCat实现分库分表
如何用DWDM射频光纤技术实现200公里外的站点
国内顺畅下载k8s.gcr.io的镜像
自动化测试appium
ctfshow ssrf
Linux操作系统学习之实用指令(Centos7/8均
上一篇文章      下一篇文章      查看所有文章
加:2022-09-30 01:24:17  更:2022-09-30 01:28:12 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年12日历 -2024/12/28 3:43:38-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码
数据统计