1.linux下socket 网络编程(客户端向服务器端发送文件) 求源代码 大哥大姐帮帮忙 。。溯源码经销企业谢谢
2.å¦ä½ç¨OPENCVåVCå®ç°äººç¼è¯å«åè½ï¼
linux下socket 网络编程(客户端向服务器端发送文件) 求源代码 大哥大姐帮帮忙 。kami google 源码。java模块源码谢谢
server:
#include <stdio.h>
#include <errno.h>
#include <unistd.h>
#include <signal.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <syslog.h>
#include <sys/time.h>
#include <string.h>
#include <fcntl.h>
#include <sys/wait.h>
#define MAXDATASIZE
#define SERVPORT
#define BACKLOG
int SendFileToServ(const char *path,github源码插件 const char *FileName, const char *ip)
{
#define PORT
int sockfd;
int recvbytes;
char buf[MAXDATASIZE];
char send_str[MAXDATASIZE];
char filepath[] = { 0};
struct sockaddr_in serv_addr;
FILE *fp;
sprintf(filepath, "%s%s", path, FileName);
if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)
{
perror("socket");
return 1;
}
bzero(&serv_addr,sizeof(struct sockaddr_in));
serv_addr.sin_family=AF_INET;
serv_addr.sin_port=htons(PORT);
inet_aton(ip, &serv_addr.sin_addr);
int IErrCount = 0;
again:
if(connect(sockfd,(struct sockaddr *)&serv_addr,sizeof(struct sockaddr))==-1)
{
if (5 == IErrCount)
return 1;
IErrCount++;
perror("connect");
sleep(2);
goto again;
}
//if ((fp = fopen(FileName, "rb")) == NULL)
if ((fp = fopen(filepath, "rb")) == NULL)
{
perror("fopen ");
return 1;
}
recvbytes = write(sockfd, FileName, strlen(FileName));
recvbytes = read(sockfd, buf, MAXDATASIZE);
if (!memcmp(buf, "sendmsg", 7))
{
while(fgets(send_str, MAXDATASIZE, fp))
{
recvbytes = write(sockfd, send_str, strlen(send_str));
recvbytes = read(sockfd, buf, MAXDATASIZE);
if (recvbytes <= 0)
{
fclose(fp);
close(sockfd);
return 1;
}
if (memcmp(buf, "goon", 4))
{
fclose(fp);
close(sockfd);
return 1;
}
}
recvbytes = write(sockfd, "end", 3);
}
else
{
fclose(fp);
close(sockfd);
return 1;
}
memset(buf, 0, MAXDATASIZE);
if (read(sockfd, buf, MAXDATASIZE) <= 0)
{
close(sockfd);
return 2;
}
char *Eptr = "nginx reload error";
//printf("bf[%s]\n", buf);
int ret;
ret = strncmp(buf, Eptr, strlen(Eptr));
//printf("%d\n", ret);
if (!ret)
{
close(sockfd);
return 2;
}
close(sockfd);
return 0;
}
int mysyslog(const char * msg)
{
FILE *fp;
if ((fp = fopen("/tmp/tmp.log", "a+")) == NULL)
{
return 0;
}
fprintf(fp, "[%s]\n", msg);
fclose(fp);
return 0;
}
static void quit_handler(int signal)
{
kill(0, SIGUSR2);
syslog( LOG_NOTICE, "apuserv quit...");
// do something exit thing ,such as close socket ,close mysql,free list
// .....
//i end
exit(0);
}
static int re_conf = 0;
static void reconf_handler(int signal)
{
re_conf=1;
syslog(LOG_NOTICE,"apuserv reload configure file .");
// 请在循环体中判断，如果re_conf == 1，pymysql 安装 源码请再次加载配置文件。
}
static int isrunning(void)
{
int fd;
int ret;
struct flock lock;
lock.l_type = F_WRLCK;
lock.l_whence = 0;
lock.l_start = 0;
lock.l_len = 0;
const char *lckfile = "/tmp/apuserv.lock";
fd = open(lckfile,O_WRONLY|O_CREAT);
if (fd < 0) {
syslog(LOG_ERR,"can not create lock file: %s\n",lckfile);
return 1;
}
if ((ret = fcntl(fd,F_SETLK,&lock)) < 0) {
ret = fcntl(fd,F_GETLK,&lock);
if (lock.l_type != F_UNLCK) {
close(fd);
return lock.l_pid;
}
else {
fcntl(fd,F_SETLK,&lock);
}
}
return 0;
}
int MyHandleBuff(const char *buf, char *str, char *FileName, char *pth)
{
sscanf(buf, "%s %s %s", pth, FileName, str);
printf("path=%s\nfilename=%s\nip=%s\n", pth, FileName, str);
return 0;
}
int main(int argc, char **argv)
{
int sockfd,client_fd;
socklen_t sin_size;
struct sockaddr_in my_addr,remote_addr;
char buff[MAXDATASIZE];
int recvbytes;
#if 1
int pid ;
char ch ;
int ret;
int debug = 0;
signal(SIGUSR1, SIG_IGN);
signal(SIGUSR2, SIG_IGN);
signal(SIGHUP, SIG_IGN);
signal(SIGTERM, quit_handler);
syslog(LOG_NOTICE,"apuserver start....");
while ((ch = getopt(argc, argv, "dhV")) != -1) {
switch (ch) {
case 'd':
debug = 1;
break;
case 'V':
printf("Version:%s\n","1.0.0");
return 0;
case 'h':
printf(" -d use daemon mode\n");
printf(" -V show version\n");
return 0;
default:
printf(" -d use daemon mode\n");
printf(" -V show version\n");
}
}
if (debug && daemon(0,0 ) ) {
return -1;
}
if (isrunning()) {
fprintf(stderr, "apuserv is already running\n");
syslog(LOG_INFO,"apuserv is already running\n");
exit(0);
}
while (1) {
pid = fork();
if (pid < 0)
return -1;
if (pid == 0)
break;
while ((ret = waitpid(pid, NULL, 0)) != pid) {
syslog(LOG_NOTICE, "waitpid want %d, but got %d", pid, ret);
if (ret < 0)
syslog(LOG_NOTICE, "waitpid errno:%d", errno);
}
kill(0, SIGUSR2);
sleep(1);
syslog(LOG_NOTICE,"restart apuserver");
}
signal(SIGHUP, reconf_handler);
signal(SIGPIPE, SIG_IGN);
signal(SIGUSR1,SIG_IGN);
signal(SIGUSR2, SIG_DFL);
signal(SIGTERM, SIG_DFL);
#endif
if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)
{
perror("socket");
exit(1);
}
bzero(&my_addr,sizeof(struct sockaddr_in));
my_addr.sin_family=AF_INET;
my_addr.sin_port=htons(SERVPORT);
my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1)
{
perror("bind");
exit(1);
}
if(listen(sockfd,BACKLOG)==-1)
{
perror("listen");
exit(1);
}
int nret;
while(1)
{
sin_size = sizeof(struct sockaddr_in);
if((client_fd = accept(sockfd, (struct sockaddr *)&remote_addr, &sin_size))==-1)
{
perror("falied accept");
continue;
}
memset(buff, 0, MAXDATASIZE);
recvbytes = read(client_fd, buff, MAXDATASIZE);
char str[] = { 0};
char FileName[] = { 0};
char path[] = { 0};
MyHandleBuff(buff, str, FileName, path);
if (recvbytes > 0)
{
nret = SendFileToServ(path, FileName, str);
printf("nret[%d]\n", nret);
if (1 == nret)
write(client_fd, "send file error", );
else if(2 == nret)
write(client_fd, "reload nginx error", );
else
write(client_fd, "succ", 4);
}
close(client_fd);
}
}
_________________________________________________
client:
#include <stdio.h>
#include <errno.h>
#include <unistd.h>
#include <signal.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <syslog.h>
#include <sys/time.h>
#include <string.h>
#include <fcntl.h>
#include <sys/wait.h>
#define MAXDATASIZE
#define SERVPORT
#define BACKLOG
int mysyslog(const char * msg)
{
FILE *fp;
if ((fp = fopen("/tmp/tmp.log", "a+")) == NULL)
{
return 0;
}
fprintf(fp, "[%s]\n", msg);
fclose(fp);
return 0;
}
static void quit_handler(int signal)
{
kill(0, SIGUSR2);
syslog( LOG_NOTICE, "apuserv quit...");
// do something exit thing ,such as close socket ,close mysql,free list
// .....
//i end
exit(0);
}
static int re_conf = 0;
static void reconf_handler(int signal)
{
re_conf=1;
syslog(LOG_NOTICE,"apuserv reload configure file .");
// ·?1nf == 1￡?′μ?
static int isrunning(void)
{
int fd;
int ret;
struct flock lock;
lock.l_type = F_WRLCK;
lock.l_whence = 0;
lock.l_start = 0;
lock.l_len = 0;
const char *lckfile = "/tmp/dstserver.lock";
fd = open(lckfile,O_WRONLY|O_CREAT);
if (fd < 0) {
syslog(LOG_ERR,"can not create lock file: %s\n",lckfile);
return 1;
}
if ((ret = fcntl(fd,F_SETLK,&lock)) < 0) {
ret = fcntl(fd,F_GETLK,&lock);
if (lock.l_type != F_UNLCK) {
close(fd);
return lock.l_pid;
}
else {
fcntl(fd,F_SETLK,&lock);
}
}
return 0;
}
int main(int argc, char **argv)
{
int sockfd,client_fd;
socklen_t sin_size;
struct sockaddr_in my_addr,remote_addr;
char buff[MAXDATASIZE];
int recvbytes;
#if 1
int pid ;
char ch ;
int ret;
int debug = 0;
signal(SIGUSR1, SIG_IGN);
signal(SIGUSR2, SIG_IGN);
signal(SIGHUP, SIG_IGN);
signal(SIGTERM, quit_handler);
syslog(LOG_NOTICE,"dstserver start....");
while ((ch = getopt(argc, argv, "dhV")) != -1) {
switch (ch) {
case 'd':
debug = 1;
break;
case 'V':
printf("Version:%s\n","1.0.0");
return 0;
case 'h':
printf(" -d use daemon mode\n");
printf(" -V show version\n");
return 0;
default:
printf(" -d use daemon mode\n");
printf(" -V show version\n");
}
}
if (debug && daemon(0,0 ) ) {
return -1;
}
if (isrunning()) {
fprintf(stderr, "dstserver is already running\n");
syslog(LOG_INFO,"dstserver is already running\n");
exit(0);
}
while (1) {
pid = fork();
if (pid < 0)
return -1;
if (pid == 0)
break;
while ((ret = waitpid(pid, NULL, 0)) != pid) {
syslog(LOG_NOTICE, "waitpid want %d, but got %d", pid, ret);
if (ret < 0)
syslog(LOG_NOTICE, "waitpid errno:%d", errno);
}
kill(0, SIGUSR2);
sleep(1);
syslog(LOG_NOTICE,"restart apuserver");
}
signal(SIGHUP, reconf_handler);
signal(SIGPIPE, SIG_IGN);
signal(SIGUSR1,SIG_IGN);
signal(SIGUSR2, SIG_DFL);
signal(SIGTERM, SIG_DFL);
#endif
if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)
{
perror("socket");
exit(1);
}
bzero(&my_addr,sizeof(struct sockaddr_in));
my_addr.sin_family=AF_INET;
my_addr.sin_port=htons(SERVPORT);
my_addr.sin_addr.s_addr = htonl(INADDR_ANY);
if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr))==-1)
{
perror("bind");
exit(1);
}
if(listen(sockfd,BACKLOG)==-1)
{
perror("listen");
exit(1);
}
char filepath[MAXDATASIZE]= { 0};
FILE *fp;
while(1)
{
sin_size = sizeof(struct sockaddr_in);
if((client_fd = accept(sockfd, (struct sockaddr *)&remote_addr, &sin_size))==-1)
{
perror("falied accept");
continue;
}
memset(buff, 0, MAXDATASIZE);
recvbytes = read(client_fd, buff, MAXDATASIZE);
sprintf(filepath, "/etc/nginx/url_rule/%s", buff);
if ((fp = fopen(filepath, "wb")) == NULL)
{
perror("fopen");
close(client_fd);
continue;
}
write(client_fd, "sendmsg", 7);
while(read(client_fd, buff, MAXDATASIZE))
{
if (!memcmp(buff, "end", 3))
{
fclose(fp);
break;
}
else
{
fprintf(fp, "%s", buff);
write(client_fd, "goon", 4);
}
}
//system("nginx -s reload");
char *Sptr = "nginx reload succ";
char *Eptr = "nginx reload error";
int ret;
ret = system("nginx -s reload");
printf("ret[%d]\n", ret);
if (ret != 0)
{
write(client_fd, Eptr, strlen(Eptr));
}
else
{
write(client_fd, Sptr, strlen(Sptr));
}
close(client_fd);
}
}
以前写的：内容忘记了。不是很复杂你可以自己看！
å¦ä½ç¨OPENCVåVCå®ç°äººç¼è¯å«åè½ï¼
ããç»ä½ 个代ç ï¼äººç¼çè¯å«ï¼
ãã#include "stdafx.h"
ãã#include "cv.h"
ãã#include "highgui.h"
ãã#include <stdio.h>
ãã#ifdef _EiC
ãã#define WIN
ãã#endif
ããstatic CvMemStorage* storage = 0;
ããstatic CvHaarClassifierCascade* cascade = 0;
ããvoid detect_and_draw( IplImage* image );
ããconst char* cascade_name =
ãã"haarcascade_eye.xml";//人è¸æ£æµåç±»å¨
ããint main( int argc, char** argv )
ãã{
ããCvCapture* capture = 0;
ããIplImage *frame, *frame_copy = 0;
ããint optlen = strlen("--cascade=");
ããconst char* input_name;
ããif( argc > 1 && strncmp( argv[1], "--cascade=", optlen ) == 0 )
ãã{
ããcascade_name = argv[1] + optlen;
ããinput_name = argc > 2 ? argv[2] : 0;
ãã}
ããelse
ãã{
ããcascade_name = "C:/OpenCV2.0/data/haarcascades/haarcascade_eye.xml";//åç±»å¨è·¯å¾
ããinput_name = argc > 1 ? argv[1] : 0;
ãã}
ããcascade = (CvHaarClassifierCascade*)cvLoad( cascade_name, 0, 0, 0 );
ããif( !cascade )//å¦æ没ææ¾å°åç±»å¨ï¼è¾åºä»¥ä¸
ãã{
ããfprintf( stderr, "ERROR: Could not load classifier cascade\n" );
ããfprintf( stderr,
ãã"Usage: facedetect --cascade=\"<cascade_path>\" [filename|camera_index]\n" );
ããreturn -1;
ãã}
ããstorage = cvCreateMemStorage(0);
ããcapture = cvCaptureFromCAM( !input_name ? 0 : input_name[0] - '0' );//读åæå头
ããif(!capture)//å¦æ没ææå头读åè§é¢æ件
ããcapture = cvCaptureFromAVI("æ£æµ.avi");
ããcvNamedWindow( "result", 1);//å建çªå£
ããif( capture )
ãã{
ããfor(;;)
ãã{
ããif( !cvGrabFrame( capture ))//ä»æå头ä¸æå帧
ããbreak;
ããframe = cvRetrieveFrame( capture );//读åä¸è¾¹æåç帧
ããif( !frame )
ããbreak;
ããif( !frame_copy )
ããframe_copy = cvCreateImage( cvSize(frame->width,frame->height),
ããIPL_DEPTH_8U, frame->nChannels );
ããif( frame->origin == IPL_ORIGIN_TL )
ããcvCopy( frame, frame_copy, 0 );
ããelse
ããcvFlip( frame, frame_copy, 0 );
ããdetect_and_draw( frame_copy );
ããif( cvWaitKey( ) >= 0 )
ããbreak;
ãã}
ããcvReleaseImage( &frame_copy );
ããcvReleaseCapture( &capture );
ãã}
ããelse//没æ£æµå°è§é¢æ件æè æå头
ãã{
ããconst char* filename = (char*)"æ£æµ.jpg";//读å¾ç
ããIplImage* image = cvLoadImage( filename, 1 );
ããif( image )
ãã{
ããdetect_and_draw( image );
ããcvWaitKey(0);
ããcvReleaseImage( &image );
ãã}
ããelse
ãã{
ããFILE* f = fopen( filename, "rt" );
ããif( f )
ãã{
ããchar buf[+1];
ããwhile( fgets( buf, , f ) )
ãã{
ããint len = (int)strlen(buf);
ããwhile( len > 0 && isspace(buf[len-1]) )
ããlen--;
ããbuf[len] = '\0';
ããimage = cvLoadImage( buf, 1 );
ããif( image )
ãã{
ããdetect_and_draw( image );
ããcvWaitKey(0);
ããcvReleaseImage( &image );
ãã}
ãã}
ããfclose(f);
ãã}
ãã}
ãã}
ããcvDestroyWindow("result");
ããreturn 0;
ãã}
ããvoid detect_and_draw( IplImage* img )
ãã{
ããstatic CvScalar colors[] =
ãã{
ãã{ { 0,0,}},
ãã{ { 0,,}},
ãã{ { 0,,}},
ãã{ { 0,,0}},
ãã{ { ,,0}},
ãã{ { ,,0}},
ãã{ { ,0,0}},
ãã{ { ,0,}}
ãã};
ããdouble scale = 1.3;
ããIplImage* gray = cvCreateImage( cvSize(img->width,img->height), 8, 1 );
ããIplImage* small_img = cvCreateImage( cvSize( cvRound (img->width/scale),
ããcvRound (img->height/scale)),
ãã8, 1 );
ããint i;
ããcvCvtColor( img, gray, CV_BGR2GRAY );
ããcvResize( gray, small_img, CV_INTER_LINEAR );
ããcvEqualizeHist( small_img, small_img );
ããcvClearMemStorage( storage );
ããif( cascade )
ãã{
ããdouble t = (double)cvGetTickCount();
ããCvSeq* faces = cvHaarDetectObjects( small_img, cascade, storage,
ãã1.1, 2, 0/*CV_HAAR_DO_CANNY_PRUNING*/,
ããcvSize(, ) );//æ£æµäººè¸è¿åç©å½¢äººè¸
ããt = (double)cvGetTickCount() - t;
ããprintf( "detection time = %gms\n", t/((double)cvGetTickFrequency()*.) );
ããfor( i = 0; i < (faces ? faces->total : 0); i++ )//æ¾å°ç©å½¢ä¸å¿ï¼æç©å½¢è½¬å为åå½¢
ãã{
ããCvRect* r = (CvRect*)cvGetSeqElem( faces, i );
ããCvPoint center;
ããint radius;
ããcenter.x = cvRound((r->x + r->width*0.5)*scale);
ããcenter.y = cvRound((r->y + r->height*0.5)*scale);
ããradius = cvRound((r->width + r->height)*0.*scale);
ããcvCircle( img, center, radius, colors[i%8], 3, 8, 0 );
ãã}
ãã}
ããcvShowImage( "result", img );
ããcvReleaseImage( &gray );
ããcvReleaseImage( &small_img );
ãã}
stream高级源码_streamsets源码
源码gu
CollectionUtils源码
vivadoIP源码
json生成源码_json代码生成器
libxvid源码
