1 实现最简单的udp socket 模型，实现发送一个字符串。
2 实现一个简单的打开文件，读取文件的例子，如用fgets(),类似的函数有很多，然后再把读取的文件内容忘另一个文件里写(相关函数fopen(),write(),read())。
3 把上面两个函数结合到一起，在客户端实现打开要传送的文件，按一定的大小读取，读取后调用sendto（）发送到服务器端。在服务器端创建一个文件，然后调用recvfrom（）接受客户端发送过来的数据，向来是创建的那个文件中写。
下面是改好的udp发送文件的例子。
服务器端程序的编译
gcc -o file_server file_server
客户端程序的编译
gcc -o file_client file_client.c
服务器程序和客户端程应当分别运行在2台计算机上.
服务器端程序的运行,在一个计算机的终端执行
./file_server
客户端程序的运行,在另一个计算机的终端中执行
./file_client 运行服务器程序的计算机的IP地址
根据提示输入要传输的服务器上的文件，该文件在服务器的运行目录上
在实际编程和测试中,可以用2个终端代替2个计算机,这样就可以在一台计算机上测试网络程序,
服务器端程序的运行,在一个终端执行
./file_server
客户端程序的运行,在另一个终端中执行
./file_client 127.0.0.1
说明: 任何计算机都可以通过127.0.0.1访问自己. 也可以用计算机的实际IP地址代替127.0.0.1
//////////////////////////////////////////////////////////////////////////////////////
// file_server.c 文件传输顺序服务器示例
//////////////////////////////////////////////////////////////////////////////////////
//本文件是服务器的代码
#include <netinet/in.h> // for sockaddr_in
#include <sys/types.h> // for socket
#include <sys/socket.h> // for socket
#include <stdio.h> // for printf
#include <stdlib.h> // for exit
#include <string.h> // for bzero
/*
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
*/
#define HELLO_WORLD_SERVER_PORT 6666
#define LENGTH_OF_LISTEN_QUEUE 20
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512
int main(int argc, char **argv)
{
//设置一个socket地址结构server_addr,代表服务器internet地址, 端口
struct sockaddr_in server_addr， pcliaddr
bzero(&server_addr,sizeof(server_addr))//把一段内存区的内容全部设置为0
server_addr.sin_family = AF_INET
server_addr.sin_addr.s_addr = htons(INADDR_ANY)
server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT)
//创建用于internet的据报套接字（UDPt,用server_socket代表服务器socket
// 创建数据报套接字（UDP）
int server_socket = socket(PF_INET,SOCK_DGRAM,0)
if( server_socket <0)
{
printf("Create Socket Failed!")
exit(1)
}
//把socket和socket地址结构联系起来
if( bind(server_socket,(struct sockaddr*)&server_addr,sizeof(server_addr)))
{
printf("Server Bind Port : %d Failed!", HELLO_WORLD_SERVER_PORT)
exit(1)
}
while (1) //服务器端要一直运行
{
//定义客户端的socket地址结构client_addr
struct sockaddr_in client_addr
socklen_t n = sizeof(client_addr)
int length
char buffer[BUFFER_SIZE]
bzero(buffer, BUFFER_SIZE)
length = recvfrom(new_server_socket,buffer,BUFFER_SIZE,0,&pcliaddr,&n)
if (length <0)
{
printf("Server Recieve Data Failed!\n")
break
}
char file_name[FILE_NAME_MAX_SIZE+1]
bzero(file_name, FILE_NAME_MAX_SIZE+1)
strncpy(file_name, buffer, strlen(buffer)>FILE_NAME_MAX_SIZE?FILE_NAME_MAX_SIZE:strlen(buffer))
// int fp = open(file_name, O_RDONLY)
// if( fp <0 )
FILE * fp = fopen(file_name,"r")
if(NULL == fp )
{
printf("File:\t%s Not Found\n", file_name)
}
else
{
bzero(buffer, BUFFER_SIZE)
int file_block_length = 0
// while( (file_block_length = read(fp,buffer,BUFFER_SIZE))>0)
while( (file_block_length = fread(buffer,sizeof(char),BUFFER_SIZE,fp))>0)
{
printf("file_block_length = %d\n",file_block_length)
//发送buffer中的字符串到new_server_socket,实际是给客户端
if(send(new_server_socket,buffer,file_block_length,0)<0)
{
printf("Send File:\t%s Failed\n", file_name)
break
}
bzero(buffer, BUFFER_SIZE)
}
// close(fp)
fclose(fp)
printf("File:\t%s Transfer Finished\n",file_name)
}
}
}
//////////////////////////////////////////////////////////////////////////////////////
// file_client.c 文件传输客户端程序示例
//////////////////////////////////////////////////////////////////////////////////////
//本文件是客户机的代码
#include <netinet/in.h> // for sockaddr_in
#include <sys/types.h> // for socket
#include <sys/socket.h> // for socket
#include <stdio.h> // for printf
#include <stdlib.h> // for exit
#include <string.h> // for bzero
/*
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>
*/
#define HELLO_WORLD_SERVER_PORT 6666
#define BUFFER_SIZE 1024
#define FILE_NAME_MAX_SIZE 512
int main(int argc, char **argv)
{
if (argc != 2)
{
printf("Usage: ./%s ServerIPAddress\n",argv[0])
exit(1)
}
//设置一个socket地址结构client_addr,代表客户机internet地址, 端口
struct sockaddr_in client_addr
bzero(&client_addr,sizeof(client_addr))//把一段内存区的内容全部设置为0
client_addr.sin_family = AF_INET //internet协议族
client_addr.sin_addr.s_addr = htons(INADDR_ANY)//INADDR_ANY表示自动获取本机地址
client_addr.sin_port = htons(0) //0表示让系统自动分配一个空闲端口
//创建用于internet的流协议(TCP)socket,用client_socket代表客户机socket
int client_socket = socket(AF_INET,SOCK_DGRAM,0)
if( client_socket <0)
{
printf("Create Socket Failed!\n")
exit(1)
}
//设置一个socket地址结构server_addr,代表服务器的internet地址, 端口
struct sockaddr_in server_addr
bzero(&server_addr,sizeof(server_addr))
server_addr.sin_family = AF_INET
if(inet_aton(argv[1],&server_addr.sin_addr) == 0) //服务器的IP地址来自程序的参数
{
printf("Server IP Address Error!\n")
exit(1)
}
server_addr.sin_port = htons(HELLO_WORLD_SERVER_PORT)
socklen_t server_addr_length = sizeof(server_addr)
char file_name[FILE_NAME_MAX_SIZE+1]
bzero(file_name, FILE_NAME_MAX_SIZE+1)
printf("Please Input File Name On Server:\t")
scanf("%s", file_name)
char buffer[BUFFER_SIZE]
bzero(buffer,BUFFER_SIZE)
strncpy(buffer, file_name, strlen(file_name)>BUFFER_SIZE?BUFFER_SIZE:strlen(file_name))
//向服务器发送buffer中的数据
socklen_t n = sizeof(server_addr)
sendto(client_socket,buffer,BUFFER_SIZE,0,(struct sockaddr*)&server_addr,n)
// int fp = open(file_name, O_WRONLY|O_CREAT)
// if( fp <0 )
FILE * fp = fopen(file_name,"w")
if(NULL == fp )
{
printf("File:\t%s Can Not Open To Write\n", file_name)
exit(1)
}
//从服务器接收数据到buffer中
bzero(buffer,BUFFER_SIZE)
int length = 0
while( length = recv(client_socket,buffer,BUFFER_SIZE,0))
{
if(length <0)
{
printf("Recieve Data From Server %s Failed!\n", argv[1])
break
}
// int write_length = write(fp, buffer,length)
int write_length = fwrite(buffer,sizeof(char),length,fp)
if (write_length<length)
{
printf("File:\t%s Write Failed\n", file_name)
break
}
bzero(buffer,BUFFER_SIZE)
}
printf("Recieve File:\t %s From Server[%s] Finished\n",file_name, argv[1])
return 0
}
linux中的一个特殊文件： /dev/tcp ,打开这个文件就类似于发出了一个socket调用，建立一个socket连接，读写这个文件就相当于在这个socket连接中传输数据。
/dev/[tcp|upd]/host/port 只要读取或者写入这个文件，相当于系统会尝试连接:host 这台机器，对应port端口。如果主机以及端口存在，就建立一个socket 连接。将在，/proc/self/fd目录下面，有对应的文件出现。
以读写方式打开/dev/tcp，并指定服务器名为： www.csdn.net ,端口号为：80,指定描述符为8。
要注意的是：/dev/tcp本身是不存在的。
向文件中随便写一些数据：
GET请求发送给socket连接。
读取返回的信息：
从socket读取返回信息，显示为标准输出
关闭socket的输入，输出
https://blog.csdn.net/zhjutao/article/details/8622751
https://www.cnblogs.com/chengmo/archive/2010/10/22/1858302.html
socket - 创建一个用于通信的端点
socket() 创建用于通信的端点并返回引用该端点的文件描述符。 成功调用时返回的文件描述符，将是当前没有被进程打开的所有文件描述符中编号最低的。
domain 参数指定一个通信域； 以决定用于通信的协议族。 这些系列在 <sys/socket.h>中定义。 目前 Linux 内核理解的格式包括：
当然最常用的当然是 AF_INET ，即IPV4。
上述地址族的更多详细信息以及其他几个地址族的信息可以在 address_families(7) 中找到。
套接字具有指定的 type ，它指定了通信语义。 当前定义的类型有：
某些套接字类型可能不会被所有协议族实现。
从 Linux 2.6.27 开始，type 参数有第二个用途：除了指定套接字类型之外，它还可以包含以下任何值的按位或，以修改 socket() 的行为：
老朋友了，上述两个，第一个是非阻塞，第二个是执行exec时自动关闭。
protocol 指定要与套接字一起使用的特定协议。 通常只存在一个协议来支持给定协议族中的特定套接字类型 ，在这种情况下，protocol 可以指定为 0。但是，可能存在许多协议，在这种情况下，必须在此指定特定协议方式。 特定协议对应的编号可以查看文件: /etc/protocols
SOCK_STREAM 类型的套接字是全双工字节流。 它们不保留记录边界。 流套接字必须处于连接状态，然后才能在其上发送或接收任何数据。 到另一个套接字的连接是通过 connect(2) 调用创建的。 连接后，可以使用 read(2) 和 write(2) 调用或 其变体send(2) 和 recv(2) 的来传输数据。 当会话完成时，可以执行 close(2)。 带外数据也可以按照 send(2) 中的描述进行传输，并按照 recv(2) 中的描述进行接收。
实现 SOCK_STREAM 的通信协议确保数据不会丢失或重复。 如果协议的缓冲空间中存在一条数据在合理的时间内不能成功传输，则认为该连接已失效。 当 SO_KEEPALIVE 在套接字上启用时，将会以特定于协议的方式检查另一端是否仍然存在。 如果进程在损坏的流上发送或接收，则会引发 SIGPIPE 信号； 这会导致不处理信号的进程退出。 SOCK_SEQPACKET 套接字使用与 SOCK_STREAM 套接字相同的系统调用。 唯一的区别是 read(2) 调用将只返回请求的数据量，到达数据包中剩余的其他数据都将被丢弃。 传入数据报中的所有消息边界也被保留。
SOCK_DGRAM 和 SOCK_RAW 套接字允许将数据报发送到在 sendto(2) 调用中指定的通信者。 数据报通常用 recvfrom(2) 接收，它返回下一个数据报及其发送者的地址。
SOCK_PACKET 是一种过时的套接字类型，用于直接从设备驱动程序接收原始数据包。 改用 packet(7)。
An fcntl(2) F_SETOWN operation can be used to specify a process or process group to receive a SIGURG signal when the out-of-band data arrives or SIGPIPE signal when a SOCK_STREAM connection breaks unexpectedly. This operation may also be used to set the process or process group that receives the I/O and asynchronous notification of I/O events via SIGIO. Using F_SETOWN is equivalent to an ioctl(2) call with the FIOSETOWN or SIOCSPGRP argument.
When the network signals an error condition to the protocol module (e.g., using an ICMP message for IP) the pending error flag is set for the socket. The next operation on this socket will return the error code of the pending error. For some protocols it is possible to enable a per-socket error queue to retrieve detailed information about the errorsee IP_RECVERR in ip(7).
套接字的 *** 作由套接字选项控制。 这些选项在 <sys/socket.h>中定义。 函数setsockopt(2) 和getsockopt(2) 用于设置和获取选项。对于选项的描述，详见socket(7).
成功时，将返回新套接字的文件描述符。 出错时，返回 -1，并设置 errno 以指示错误。
POSIX.1-2001, POSIX.1-2008, 4.4BSD.
The SOCK_NONBLOCK and SOCK_CLOEXEC flags are Linux-specific.
socket() appeared in 4.2BSD. It is generally portable to/from non-BSD systems supporting clones of the BSD socket layer (including System V variants).
在 4.x BSD 下用于协议族的清单常量是 PF_UNIX、PF_INET 等，而 AF_UNIX、AF_INET 等用于地址族。 但是，BSD 手册页已经承诺：“协议族通常与地址族相同”，随后的标准到处都使用 AF_*。
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）