[HttpSQS]入队和出队的一个简单示例,C实现put/get/view简单模拟http请求功能代码。

jackxiang 2013-8-19 17:38

<?php
     echo "Que Test Begin:\n";
     Error_reporting(E_ALL);
     $host = "192.168.109.7";
     $port = "1218";
     $query = "/?charset=utf8&name=playRecord&opt=put";
     $body = "%7B%22action%22%3A%22update%22%2C%22where%22%3A%7B%22user_id%22%3A18862170%2C%22video_id%22%3A%220f7b104c-f29c-11e2-b474-a4badb4689bc%22%7D%2C%22data%22%3A%7B%22position%22%3A-1%2C%22clienttype%22%3A1%7D%7D";
     //上面的经过UrlDecode解码后：{"action":"update","where":{"user_id":18862170,"video_id":"0f7b104c-f29c-11e2-b474-a4badb4689bc"},"data":{"position":-1,"clienttype":1}}
     $result = httpPost($host, $port, $query, $body);
     echo "sendToQueue:\n";
     echo $result;
     usleep(200000);//0.2秒
     $query = "/?charset=utf8&name=playRecord&opt=get";
     echo "\ngetFromQueue:\n";
     $result = httpGet($host, $port, $query);
     print_r($result);

<?php
     function httpPost($host, $port, $query, $body)
     {
         $fp = fsockopen($host, $port, $errno, $errstr, 1);
         if (!$fp) {
             return false;
         }
         $out = "POST ${query} HTTP/1.1\r\n";
         $out .= "Host: ${host}\r\n";
         $out .= "Content-Length: " . strlen($body) . "\r\n";
         $out .= "Connection: close\r\n";
         $out .= "\r\n";
         $out .= $body;
         fwrite($fp, $out);
         $line = trim(fgets($fp));
         $pos_value = "";
         list($proto, $rcode, $result) = explode(" ", $line);
         $len = -1;
         while (($line = trim(fgets($fp))) != "") {
             if (strstr($line, "Content-Length:")) {
                 list($cl, $len) = explode(" ", $line);
             }
             if (strstr($line, "Pos:")) {
                 list($pos_key, $pos_value) = explode(" ", $line);
             }
         }
         fclose($fp);
         return ($len < 0) ? false : (int)$pos_value;
     }

运行一下如下：
php playRecord.php
Que Test Begin:
sendToQueue:
2606
getFromQueue:
Array
(
[pos] => 2606
[data] => {"action":"update","where":{"user_id":18862170,"video_id":"0f7b104c-f29c-11e2-b474-a4badb4689bc"},"data":{"position":-1,"clienttype":1}}
)

C实现put/get/view简单模拟http请求功能代码，google的SVN地址：
https://code.google.com/p/httpsqs/source/browse/trunk/client/c
E:\dev_Codes_All\httpSQS_Codes_All\C语言实现Http请求的源代码\client.c

/*
 加入独立C语言客户端client.c。实现get,put,view,status,r
  eset,maxqueue函数封装
 * ±¾³ÌÐòÊÇhttpsqsµÄCÓïÑÔ¿Í»§¶Ëº¯Êý¿â
 * Ö§³Ö£ºget put view reset maxqueue status¹¦ÄÜ£¬ÔÝ²»Ö§³Ökeep-alive
 * ±àÒë£ºgcc -o client client.c
 * Ê¹ÓÃ·½·¨£º
 * GET:       httpsqs_get(char * your_queue_name)
 * PUT:       httpsqs_put(char * your_queue_name, char * data)
 * VIEW:      httpsqs_view(char * your_queue_name, char * pos)
 * MAXQUEUE   httpsqs_maxqueue(char * your_queue_name, char * num)
 * STATUS     httpsqs_status(char * your_queue_name)
 * RESET      httpsqs_reset(char * your_queue_name)
 * ×÷Õß£ºÀî²© lb13810398408@gmail.com
 * ÈÕÆÚ£º2010Äê4ÔÂ7ÈÕ
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <stdarg.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netdb.h>

#define HttpsqsIp "192.168.1.102"
#define HttpsqsPort 1218
#define Charset "utf-8"

int htconnect(char *domain,int port)
{
        int white_sock;
        struct hostent * site;
        struct sockaddr_in me;
        site = gethostbyname(domain);
        if(site == NULL) return -2;
        white_sock = socket(AF_INET,SOCK_STREAM, 0);
        if(white_sock < 0) return -1;
        memset(&me, 0, sizeof(struct sockaddr_in));
        memcpy(&me.sin_addr, site->h_addr_list[0], site->h_length);
        me.sin_family = AF_INET;
        me.sin_port = htons(port);
        return (connect(white_sock, (struct sockaddr *)&me, sizeof(struct sockaddr)) < 0) ? -1 : white_sock;
}

int htsend(int sock,char *fmt,...)
{
        char BUF[1024];
        va_list argptr;
        va_start(argptr, fmt);
        vsprintf(BUF,fmt, argptr);
        va_end(argptr);
        return send(sock, BUF, strlen(BUF), 0);
}

int http_get(char * query)
{
        int black_sock;

black_sock = htconnect(HttpsqsIp, HttpsqsPort);
        if (black_sock < 0) return;

htsend(black_sock, "GET %s HTTP/1.1\r\n", query, 10);
        htsend(black_sock, "Host: %s\r\n", HttpsqsIp, 10);
        htsend(black_sock, "Connection: close\r\n", 10);
        htsend(black_sock, "\r\n", 10);

return black_sock;
}

int http_put(char * data, char * query)
{
        int black_sock;
        int len = 0;

black_sock = htconnect(HttpsqsIp, HttpsqsPort);
        if (black_sock < 0) return;
        len = strlen(data);
        htsend(black_sock, "POST %s HTTP/1.1\r\n", query, 10);
        htsend(black_sock, "Host: %s\r\n", HttpsqsIp, 10);
        htsend(black_sock, "Content-Length: %d\r\n", len, 10);
        htsend(black_sock, "Connection: close\r\n", 10);
        htsend(black_sock, "\r\n", 10);
        htsend(black_sock, "%s", data, 10);

return black_sock;
}

char * httpsqs_maxqueue(char * name, char * num)
{
        char data[3];
        int sock;
        char * query;
        char max[300];
        int i = 0, j = 0;
        char * fs;

query = (char *)malloc((strlen(name) + strlen(num) + strlen(Charset) + 35) * sizeof(char));
        sprintf(query, "/?charset=%s&name=%s&opt=maxqueue&num=%s", Charset, name, num);

sock = http_get(query);
        free(query);

while (read(sock, data, 1) > 0)
        {
                if(j >= 7)
                {
                        max[i] = data[0];
                        i ++;
                }
                if(data[0] == '\n')
                {
                        j ++;
                }
        }

if(strlen(max) > 0)
        {
                max[i] = '\0';
        }
        fs = (char *)malloc(strlen(max) * sizeof(char));
        strcpy(fs, max);
        return fs;
}

char * httpsqs_reset(char * name)
{
        char data[3];
        int sock;
        char * query;
        char reset[300];
        int i = 0, j = 0;
        char * fs;

query = (char *)malloc((strlen(name) + strlen(Charset) + 27) * sizeof(char));
        sprintf(query, "/?charset=%s&name=%s&opt=reset", Charset, name);

sock = http_get(query);
        free(query);

while (read(sock, data, 1) > 0)
        {
                if(j >= 7)
                {
                        reset[i] = data[0];
                        i ++;
                }
                if(data[0] == '\n')
                {
                        j ++;
                }
        }
        if(strlen(reset) > 0)
        {
                reset[i] = '\0';
        }
        fs = (char *)malloc(strlen(reset) * sizeof(char));
        strcpy(fs, reset);
        return fs;
}

char * httpsqs_status(char * name)
{
        char data[3];
        int sock;
        char * query;
        char status[300];
        int i = 0, j = 0;
        char * fs;

query = (char *)malloc((strlen(name) + strlen(Charset) + 28) * sizeof(char));
        sprintf(query, "/?charset=%s&name=%s&opt=status", Charset, name);

sock = http_get(query);
        free(query);

while (read(sock, data, 1) > 0)
        {
                if(j >= 7)
                {
                        status[i] = data[0];
                        i ++;
                }
                if(data[0] == '\n')
                {
                        j ++;
                }
        }
        if(strlen(status) > 0)
        {
                status[i] = '\0';
        }
        fs = (char *)malloc(strlen(status) * sizeof(char));
        strcpy(fs, status);
        return fs;
}

char * httpsqs_put(char * name, char * bodydata)
{
        char data[3];
        char dataarr[2][20];
        char pos[10];
        int sock;
        char * query;
        int i = 0, j = 0, flag = 0;

char queuedata[2000];
        char * fq;
        //fq = queuedata;

query = (char *)malloc((strlen(name) + strlen(Charset) + 25) * sizeof(char));
        sprintf(query, "/?charset=%s&name=%s&opt=put", Charset, name);

sock = http_put(bodydata, query);
        free(query);

memset(dataarr[0], 0, strlen(dataarr[0]));
        memset(dataarr[1], 0, strlen(dataarr[1]));
        while (read(sock, data, 1) > 0)
        {
                if(j == 3)
                {
                        if(data[0] == 'P')
                        {
                                flag = 1;
                        }
                        if(flag == 1)
                        {
                                i++;
                                if(i >= 6)
                                {
                                        dataarr[0][i-6] = data[0];
                                }
                        }
                }
                if(j == 4 && strlen(dataarr[0]) > 2)
                {
                        for(i = 0; i < strlen(dataarr[0])-2; i++)
                        {
                                pos[i] = dataarr[0][i];
                        }
                        pos[strlen(pos)] = '\0';
                        memset(dataarr[0], 0, strlen(dataarr[0]));
                        strcpy(dataarr[0], pos);
                        i = 0;
                        if(strlen(pos) > 0)
                        {
                                flag = 2;
                        }
                }
                if(flag == 2 && strlen(pos) > 0)
                {
                        if(j == 8)
                        {
                                dataarr[1][i] = data[0];
                                i++;
                        }
                }
                if(data[0] == '\n')
                {
                        j ++;
                }

}
        if(strlen(dataarr[1]) > 0)
        {
                dataarr[1][i] = '\0';
        }
        memset(queuedata, 0, strlen(queuedata));
        sprintf(queuedata, "Pos:%s\nData:%s", dataarr[0], dataarr[1]);
        fq = (char *)malloc(strlen(queuedata) * sizeof(char));
        strcpy(fq, queuedata);
        //printf("%s\n\n\n", queuedata);
        return fq;
}

char * httpsqs_view(char * name, char * pos)
{
        char data[3];
        int sock;
        char * query;
        int i = 0, j = 0;

char queuedata[2000];
        char * fq;

query = (char *)malloc((strlen(name) + strlen(Charset) + strlen(pos) + 31) * sizeof(char));
        sprintf(query, "/?charset=%s&name=%s&opt=view&pos=%s", Charset, name, pos);

sock = http_get(query);
        free(query);

while (read(sock, data, 1) > 0)
        {
                if(j >= 7)
                {
                        queuedata[i] = data[0];
                        i ++;
                }
                if(data[0] == '\n')
                {
                        j ++;
                }
        }
        if(strlen(queuedata) > 0)
        {
                queuedata[i] = '\0';
        }
        fq = (char *)malloc(strlen(queuedata) * sizeof(char));
        strcpy(fq, queuedata);
        return fq;
}

char * httpsqs_get(char * name)
{
        char data[3];
        char dataarr[2][2000];
        char pos[10];
        int sock;
        char * query;
        int i = 0, j = 0, flag = 0;

char queuedata[2000];
        char * fq;

query = (char *)malloc((strlen(name) + strlen(Charset) + 25) * sizeof(char));
        sprintf(query, "/?charset=%s&name=%s&opt=get", Charset, name);

sock = http_get(query);
        free(query);

if(strlen(dataarr[1]) > 0)
        {
                dataarr[1][strlen(dataarr[1])] = '\0';
        }

memset(queuedata, 0, strlen(queuedata));
        sprintf(queuedata, "Pos:%s\nData:%s", dataarr[0], dataarr[1]);
        fq = (char *)malloc(strlen(queuedata) * sizeof(char));
        strcpy(fq, queuedata);
        return fq;
}

int main(int argc,char **argv)
{
        char * data;

data = httpsqs_put(argv[1], argv[2]);
        printf("%s\n", data);
        free(data);

data = httpsqs_status(argv[1]);
        printf("%s\n", data);
        free(data);

data = httpsqs_get(argv[1]);
        printf("%s\n", data);
        free(data);

data = httpsqs_reset(argv[1]);
        printf("%s\n", data);
        free(data);
        /*
        data = httpsqs_maxqueue(argv[1], argv[2]);
        printf("%s\n", data);
        free(data);

data = httpsqs_view(argv[1], argv[2]);
        printf("%s\n", data);
        free(data);
        */
}

E:\dev_Codes_All\httpSQS_Codes_All\C语言实现Http请求的源代码\httpsqs_client.c

/*
 *本程序用C语言作为Linux守护进程
 *实现每秒读取队列内容平且POST发送给处理端（例如PHP程序）
 *可以修改处理队列数据部分的代码实现其他的数据处理
 *本程序只是一个最初级的作品，本人的C语言水平也很低（在写这个程序前还不会C语言的socket发送HTTP请求）
 *希望张宴大哥给予指正与修改，体现我们开源的优势～哈哈
 *
 *使用方法：
 *make
 *make install
 *httpsqs_client -q your_queue_name -t 20(每秒获取队列的次数)
 *
 *作者：李博 lb13810398408@gmail.com
 */
#include <unistd.h>
#include <signal.h> 
#include <sys/param.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <stdarg.h> 
#include <sys/socket.h> 
#include <netinet/in.h> 
#include <netdb.h>
#include <time.h>

#define HttpsqsIp "192.168.1.102"
#define HttpsqsPort 1218

#define RemoteIp "xxx.xxx.xxx.xxx"//本程序获取队列后的处理是将数据POST给PHP程序 用户可以自行修改那一部分
#define RemotePort 80

void init_daemon(void);

void init_daemon(void)
{
        int pid;
        int i;
        if(pid = fork())
                exit(0);
        else if(pid < 0)
                exit(1);
        setsid();

if(pid = fork())
                exit(0);
        else if(pid < 0)
                exit(1);

for(i = 0; i < NOFILE; ++i)
                close(i);
        chdir("/var");
        umask(0);
        return;
}

int htconnect(char *domain,int port) 
{
        int white_sock;
        struct hostent * site;
        struct sockaddr_in me;
        site = gethostbyname(domain);
        if(site == NULL) return -2;
        white_sock = socket(AF_INET,SOCK_STREAM, 0);
        if(white_sock < 0) return -1;
        memset(&me, 0, sizeof(struct sockaddr_in));
        memcpy(&me.sin_addr, site->h_addr_list[0], site->h_length);
        me.sin_family = AF_INET;
        me.sin_port = htons(port);
        return (connect(white_sock, (struct sockaddr *)&me, sizeof(struct sockaddr)) < 0) ? -1 : white_sock;
}

int htsend(int sock,char *fmt,...)
{
    char BUF[1024];
    va_list argptr;
    va_start(argptr, fmt);
    vsprintf(BUF,fmt, argptr);
    va_end(argptr);
    return send(sock, BUF, strlen(BUF), 0);
}

int httpsqs_get(char *queuename)
{
        int black_sock;

black_sock = htconnect(HttpsqsIp, HttpsqsPort);
        if (black_sock < 0) return;

htsend(black_sock, "GET /?charset=utf-8&name=%s&opt=get HTTP/1.1\r\n", queuename, 10);
        htsend(black_sock, "Host: %s\r\n", HttpsqsIp, 10);
    htsend(black_sock, "Connection: close\r\n", 10);
    htsend(black_sock, "\r\n", 10);

return black_sock;
}

int http_post(char *datastr)
{
        int black_sock;
        int len = 0;

black_sock = htconnect(RemoteIp, RemotePort);
    if (black_sock < 0) return;
    len = strlen(datastr) + 5;
    htsend(black_sock, "POST /index.php?m=feed&a=feed_add HTTP/1.1\r\n", 10);
    htsend(black_sock, "Content-type: application/x-www-form-urlencoded\r\n", 10);
    htsend(black_sock, "Host: www.oooffice.com\r\n", 10);
    htsend(black_sock, "Content-Length: %d\r\n", len, 10);
    htsend(black_sock, "Connection: close\r\n", 10);
    htsend(black_sock, "\r\n", 10);
    htsend(black_sock, "data=%s", datastr, 10);

return black_sock;
}

void process(char *queuename, int loop)
{
        FILE * fp;
        int black_sock;
    char data[3];
    char posstr[15];
    char datastr[2000];
    char post[5000];
        int i = 0;
    int j = 0;
    int len = 0;
    int flag = 0;

char pos[10];
    int p = 0;

loop --;
    while(loop)
    {
        memset(data, 0, strlen(data));
        memset(datastr, 0, strlen(datastr));
        memset(pos, 0, strlen(pos));

black_sock = httpsqs_get(queuename);

i = 0;
        j = 0;
        
        while (read(black_sock, data, 1) > 0)
            {
            if(j == 3)
            {
                if(data[0] == 'P')
                    flag = 1;
                if(flag == 1)
                {
                    i++;
                    if(i >= 6)
                        posstr[i-6] = data[0];
                }
            }
            if(j == 4 && strlen(posstr) > 2)
            {
                for(i = 0; i < strlen(posstr)-2; i++)
                    pos[i] = posstr[i];
                pos[strlen(pos)] = '\0';
                i = 0;
                if(strlen(pos) > 0)
                    flag = 2;
            }
            if(flag == 2 && strlen(pos) > 0)
            {
                if(j == 8)
                {
                    datastr[i] = data[0];
                    i++;
                }
            }
            if(data[0] == '\n')
                                j ++;
        }
        if(strlen(datastr) > 0)
            datastr[strlen(datastr)] = '\0';

if(strlen(datastr) > 0 && strlen(pos) > 0)
            printf("POS:%s\nDATA:%s\n", pos, datastr);

close(black_sock);
        memset(data, 0, strlen(data));

if(strlen(datastr) > 0 && strlen(pos) > 0)
        {
            p = atoi(pos);
        
                    if((fp = fopen("httpsqs_feed.log", "a")) >= 0)
                            fprintf(fp, "GET FROM HTTPSQS:\r\nPOS:%d\nDATA:%s\r\n", p, datastr);

//这部分是获取队列内容后的操作部分，queuedata为队列内容，p为队列的Pos
            black_sock = http_post(datastr);

i = 0;
            while (read(black_sock, data, 1)>0)
            {
                if(data[0] == '|')
                {
                    if(post[i-1] == 'D' && post[i-2] == 'N' && post[i-3] == 'E')
                    {
                        post[i-3] = '\0';
                        break;
                    }
                }
                post[i] = data[0];
                i++;
            }
            memset(data, 0, strlen(data));
            close(black_sock);
            if(strlen(post))
            {
                            if(fp >=0)
                            {
                                    strcpy(post, strstr(post, "Array"));
                                    fprintf(fp, "POST TO REMOTE\r\n%s\r\n", post);
                                    fclose(fp);
                            }
            }
        }

memset(post, 0, strlen(post));
        loop --;
    }
        return;
}

int main(int argc,char **argv) 
{ 
    char queuename[20];
    int loop;

if(argc <= 4 || strcmp(argv[1], "-q") != 0 || strcmp(argv[3], "-t") != 0)
    {
        printf("You should run program like:\n");
        printf("%s -q queuename -t timespersec\n", argv[0]);
        return;
    }

strcpy(queuename, argv[2]);
    loop = atoi(argv[4]);

if(loop < 1)
    {
        printf("The -t(times per second) must be an int number & > 0\n");
        return;
    }

init_daemon();

while(1)
    {
        sleep(1);
        process(queuename, loop);
    }
}

Makefile：

最后编辑： jackxiang 编辑于2015-2-12 13:46

PHP做守护进程出现了内存不够用的情况，有待排查。

php-fpm的hosts访问问题记录

评论列表

向东博客专注WEB应用构架之美 --- 构架之美，在于尽态极妍 | 应用之美，在于药到病除|赢在IT，Playin' with IT,Focus on Killer Application,Marketing Meets Technology.

[HttpSQS]入队和出队的一个简单示例,C实现put/get/view简单模拟http请求功能代码。

分类

最新日志

链接

向东博客 专注WEB应用 构架之美 --- 构架之美，在于尽态极妍 | 应用之美，在于药到病除|赢在IT，Playin' with IT,Focus on Killer Application,Marketing Meets Technology.

[HttpSQS]入队和出队的一个简单示例,C实现put/get/view简单模拟http请求功能代码。

分类

最新日志

链接

向东博客专注WEB应用构架之美 --- 构架之美，在于尽态极妍 | 应用之美，在于药到病除|赢在IT，Playin' with IT,Focus on Killer Application,Marketing Meets Technology.