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
}
1、连接DatagramSocket的服务端（ip和port）：开启异步线程和socket
2、发送数据（DatagramPacket）：异步
3、接收数据（DatagramPacket）：注意连接状态，异步读取
4、关闭连接：关闭DatagramSocket和对应线程
1、异常：android.os.NetworkOnMainThreadException。 socket需要在线程中使用
2、前后端统一传输或者接收协议 [requestcode size d1 d2 d3 ... ]，在解析时候用得到
3、实施监控socket的连接状态，还是用心跳包发过去，然后返回数据，一段时间没有的话则代表socket连接失败。
4、注意receive接收数据后的有效长度（一个是预存的buffer，一个是有效结果buffer）
5、客户端连上去后不知道为何一定要先发送一次，才能接收？
6、UDP不安全，有长度限制64K
2019 (*￣(oo)￣) 诸事顺利！
自己的IP地址 如果是直接入网的话(无网关 不是学校公司这种局域网入网的) 就是你上百度贴吧匿名发帖的那个IP 其他方法也有 但是这个最直观还有 SOCKET不是一个端口性质的东西 而是更像一个数据包这种样子的东西 这点很容易混淆
比如说 如果是服务器监听客户端的话 :
服务器不需要知道客户端的IP 只需要打开自己这边的一个端口(PORT) 然后建立一个SOCKET实例绑定到这个端口 然后就成功的监听了 运行后所有发送到这个端口的BYTE流都可以通过SOCKET.BEGINACCEPT方法来接收
而客户端却不但要知道服务器的IP 还要知道服务器用来监听的那个端口(PORT) 这样就形成了一个服务器ENDPOINT(IP+PORT) 然后自己生成一个SOCKET实例 再连接那个服务器ENDPOINT 再通过这个SOCKET实例传输自己的BYTE流
编IM还是很复杂的 尤其是线程和异步调用的问题 SOCKET只是第一步 和网页的那种伪IM完全不一样的
还有什么问题的话可以HI我 不过我也是菜鸟 只能尽力而为了
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）