//client.c
///udpclient.cpp
/*#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>*/
#include "udp_client.h"
int sockfd_c = 0;
struct sockaddr_in server_addr;
int initUdpClient(unsigned port, char *IP)
{
sockfd_c = socket(PF_INET,SOCK_DGRAM,0);
if(-1 == sockfd_c)
{
printf("socket error\n");
return -1;
}
bzero(&server_addr,sizeof(server_addr));
server_addr.sin_family = PF_INET;
server_addr.sin_port = htons(port);
server_addr.sin_addr.s_addr = inet_addr(IP);
printf("TTT----port[%d]---IP[%s]\n", port, IP);
return 0;
}
int uninitUdpClient()
{
close(sockfd_c);
sockfd_c = 0;
}
int c_read(char *buf, int len)
{
len = recvfrom(sockfd_c, buf, len, 0, NULL, NULL);
if(0 > len)
{
return -1;
}
return len;
}
/* ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,
const struct sockaddr *dest_addr, socklen_t addrlen); */
int c_write(char *buf, int len)
{
len = sendto(sockfd_c, buf, len, 0, (struct sockaddr *)(&server_addr), sizeof(server_addr));
if(0 > len)
{
return -1;
}
return len;
}
#if 0
int main(int argc, char * argv [ ])
{
int sockfd;
int len,i;
char buf[1024]={0};
unsigned short port = 0x9999;
struct sockaddr_in server_addr;
sockfd = socket(PF_INET,SOCK_DGRAM,0);
if(-1 == sockfd)
{
printf("socket error\n");
return -1;
}
bzero(&server_addr,sizeof(server_addr));
server_addr.sin_family = PF_INET;
server_addr.sin_port = htons(port);
server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");
printf("TTT---I will login server---->\n");
i = 0;
while(1)
{
memset(buf,0,sizeof(buf));
sprintf(buf,"hello,i am client %d",i);
len = sendto(sockfd,buf,strlen(buf),0,(struct sockaddr *)(&server_addr),sizeof(server_addr));
//std::cout<<len<<std::endl;
printf("TTT---buf[%s]----------len[%d]\n", buf, len);
sleep(1);
memset(buf,0,sizeof(buf));
sprintf(buf,"fuck fuck fuck %d",i);
len = sendto(sockfd,buf,strlen(buf),0,(struct sockaddr *)(&server_addr),sizeof(server_addr));
printf("TTT---buf[%s]----------len[%d]\n", buf, len);
sleep(1);
i++;
}
close(sockfd);
return 0;
}
#endif
=========================================================================
//client.h
#include <string.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
int initUdpClient(unsigned port, char *IP);
int uninitUdpClient();
int c_read(char *buf, int len);
int c_write(char *buf, int len);
=======================================================================
main_client.c
#include "udp_client.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <stdlib.h>
#define LEN_MAX 1024*200
int main(int argc,char * argv [ ])
{
#if 1
//int n = 18000;
//system("date");
while(1)
{
printf("TTT----I am run--n[----]--\n");
usleep(5*1000);
}
//system("date");
#else
int fd = 0;
char file_name[] = {"video2.h264"};
long file_len = 0;
long n;
int i;
long len = -1;
char *buf = (char *)malloc(LEN_MAX);
unsigned port = 0x9999;
//char IP[] = {"127.0.0.1"};
char IP[] = {"192.168.3.109"};
if(0 != initUdpClient(port, IP))
{
return -1;
}
i = 0;
n = LEN_MAX;
while((n -= 32) > 0)
{
memcpy(buf+i,"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa",32);
i += 32;
}
fd = open(file_name, O_RDONLY, 0777);
if(fd < 0)
{
printf("TTT---open fail\n");
}
else
{
printf("TTT---open file[%s]\n", file_name);
}
i = 0;
//len = LEN_MAX;
while(1)
{
// 1024*64 不能发
// 1024*63 可以
len = read(fd, buf, 1024);
if(len <= 0)
{
printf("TTT----read error--- to over\n");
break;
}
len = c_write(buf, len);
if(len < 0)
{
printf("TTT----len[%ld]---\n", len);
}else{
file_len += len;
printf("TTT----file_len[%ld]---\n", file_len);
}
usleep(10*1000);
}
uninitUdpClient();
#endif
return 0;
}
=========================================================================
=========================================================================
server.c
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include "udp_server.h"
int sockfd_s = 0;
int initUdpServer(unsigned port)
{
struct sockaddr_in server_addr;
sockfd_s = socket(PF_INET,SOCK_DGRAM,0);
if(-1 == sockfd_s)
{
printf("socket error\n");
return -1;
}
bzero(&server_addr,sizeof(server_addr));
server_addr.sin_family = PF_INET;
server_addr.sin_port = htons(port);
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
if(-1 == bind(sockfd_s,(struct sockaddr *)(&server_addr),sizeof(server_addr)))
{
printf("bind error\n");
return -1;
}
printf("TTT---UDP SERVER init success\n");
return 0;
}
int uninitUdpServer()
{
close(sockfd_s);
sockfd_s = 0;
}
int s_read(char *buf, int len)
{
len = recvfrom(sockfd_s, buf, len, 0, NULL, NULL);
if(0 > len)
{
return -1;
}
return len;
}
int s_write(char *buf, int len)
{
len = sendto(sockfd_s, buf, len, 0, NULL, NULL);
if(0 > len)
{
return -1;
}
return len;
}
#if 0
int main(int argc, char * argv [ ])
{
#if 0
int sockfd;
int len;
struct sockaddr_in server_addr;
unsigned short port = 0x9999;
char buf[1024]={0};
sockfd = socket(PF_INET,SOCK_DGRAM,0);
if(-1 == sockfd)
{
printf("socket error\n");
}
bzero(&server_addr,sizeof(server_addr));
server_addr.sin_family = PF_INET;
server_addr.sin_port = htons(port);
server_addr.sin_addr.s_addr = htonl(INADDR_ANY);
if(-1 == bind(sockfd,(struct sockaddr *)(&server_addr),sizeof(server_addr)))
{
printf("bind error\n");
return -1;
}
#endif
printf("TTT----I am wait for client msg\n");
while(1)
{
len = recvfrom(sockfd,buf,1024,0,NULL,NULL);
if(0 < len)
{
printf("%s\n", buf);
printf("TTT---buf[%s]--len[%d]\n", buf, len);
}
else
{
sleep(1);
}
}
printf("server out");
close(sockfd);
return 0;
}
#endif
=======================================================================
server.h
#include <unistd.h>
#include <stdlib.h>*/
#include <string.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
int initUdpServer(unsigned port);
int uninitUdpServer();
int s_read(char *buf, int len);
int s_write(char *buf, int len);
==========================================================================
//main_server.c
#include "udp_server.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
int main(int argc, char *argv[])
{
long file_len = 0;
int fd = 0;
char f_name[] = {"write_test2.h264"};
int len = -1;
char *buf = (char *)malloc(2048);
if(NULL == buf)
{
printf("TTT----malloc error\n");
return -1;
}
unsigned port = 0x9999;
if(-1 == initUdpServer(port))
{
return -1;
}
fd = open(f_name, O_CREAT|O_RDWR, 0777);
if(-1 == fd)
{
printf("TTT----open file\n");
return -1;
}
else
{
printf("TTT----open file[%s]\n", f_name);
}
while(1)
{
memset(buf, 0, 2048);
len = s_read(buf, 1024);
if(0 < len)
{
//printf("TTT---buf[%s]--len[%d]\n", buf, len);
len = write(fd, buf, len);
if(0 > len)
{
printf("TTT----write error--len[%d]\n", len);
}
file_len += len;
printf("TTT----file_len[%ld]---\n", file_len);
if(len < 1024)
{
break;
}
}
usleep(10*1000);
}
free(buf);
buf = NULL;
return 0;
}
