Archive for the ‘Programming’ Category.

linux进程可执行文件的绝对路径

这种情况很少遇到,我们需要一个运行中进程的绝对路径,可惜的是glibc中或者系统调用中我都没有找到类似的函数。但是绝对不会不给你这个机会的,那就是proc文件系统了。在proc文件系统中那些数字都是运行中的进程,进入一个文件名为数字的文件夹以后,我们就可以发现以下类似文件目录结构。

[cyher@cyher ~]$ ls /proc/3355/
attr             cpuset   io        mountinfo   pagemap      smaps    task
auxv             cwd      latency   mounts      personality  stack    wchan
cgroup           environ  limits    mountstats  root         stat
clear_refs       exe      loginuid  net         sched        statm
cmdline          fd       maps      oom_adj     schedstat    status
coredump_filter  fdinfo   mem       oom_score   sessionid    syscall

这里就是一个进程所有的信息了大名鼎鼎的ps命令就是读取这里的内容解析出信息的,这里是ps的官方网站 http://procps.sourceforge.net/

那好了,就用这里给的信息来解析出执行文件的绝对路径吧

/*
 * =====================================================================================
 *
 *       Filename:  get_exe_path.c
 *
 *    Description:
 *
 *        Version:  1.0
 *        Created:  2009年09月23日 17时07分17秒
 *       Revision:  none
 *       Compiler:  gcc
 *
 *         Author:  cyher (), cyher.net@gmail.com
 *        Company:  cyher.net
 *
 * =====================================================================================
 */
 
#include
#include
#include
#define BUF 128
 
int main(int agrc, char **argv) {
    char buf[BUF];
    char proc[BUF];
    char *p;
 
    sprintf(proc, "/proc/%d/exe", atoi(argv[1]));
    readlink(proc,buf, BUF); /*proc/pid/exe 是一个链接,用readlink读*/
    p = strchr(buf,'('); /*读出的路径后面有可能会有 (deleted)字样,删去*/
    if (p != NULL) {
        p--;
        *p = '\0';
    }
    puts(buf);
}

这样就能读取出绝对路径了,不过你首先要知道pid啊 呵呵。

相关日志

mysql C API(上)

Mysql,是开源界很有名的数据库,LAMP这种组合也是在web服务器领域很流行.也就是说,我们经常用的API都是一些web编程语言如:php,java,pyhton这些语言来和mysql通信,但是要是用c语言呢,我也就小小的研究一下.

文章参考:
mysql中文手册在线版
当你看完手册的时候,会发现,c语言也能像php一样
    
query = "select * from test";
mysql_query(query);
类似的语句,执行查询等数据库操作.但是C语言有一种更常用的方法,更好的方法.我们为什么用C,效率第一,所以看下面. 

为什么要用预处理?

答:MySQL客户端/服务器协议提供了预处理语句。该功能采用了由mysql_stmt_init()初始化函数返回的MYSQL_STMT语句处理程序数据结构。对于多次执行的语句,预处理执行是一种有效的方式。首先对语句进行解析,为执行作好准备。接下来,在以后使用初始化函数返回的语句句柄执行一次或多次。

对于多次执行的语句,预处理执行比直接执行快,主要原因在于,仅对查询执行一次解析操作。在直接执行的情况下,每次执行语句时,均将进行查询。此外,由于每次执行预处理语句时仅需发送参数的数据,从而减少了网络通信量。

预处理语句的另一个优点是,它采用了二进制协议,从而使得客户端和服务器之间的数据传输更有效率。

下述语句可用作预处理语句:CREATE TABLE、DELETE、DO、INSERT、REPLACE、SELECT、SET、UPDATE、以及大多数SHOW语句。在MySQL 5.1中,不支持其他语句。
下面就把我的测试程序贴出来,是完成数据库的插入一条记录:

测试数据表结构:
1
2
3
4
5
6
7
8
9
10
11
12
13
14
+------------------+--------------+------+-----+---------+----------------+
| Field            | Type         | Null | Key | Default | Extra          |
+------------------+--------------+------+-----+---------+----------------+
| USER_ID          | int(11)      | NO   | PRI | NULL    | auto_increment |
| USERNAME         | varchar(25)  | NO   |     | NULL    |                |
| PASSWORD         | varchar(25)  | NO   |     | NULL    |                |
| ARK_GROUP_ID     | int(11)      | NO   |     | NULL    |                |
| PURVIWE_GROUP_ID | int(11)      | NO   |     | NULL    |                |
| DESCRIPT         | varchar(200) | YES  |     |         |                |
| USER_POLICY      | int(11)      | YES  |     | 0       |                |
| MAIL             | varchar(50)  | YES  |     |         |                |
| PHONE            | varchar(15)  | YES  |     |         |                |
| LEVEL            | int(1)       | NO   |     | 0       |                |
+------------------+--------------+------+-----+---------+----------------+
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
/*************************************************************************************
 *                                                                                     
 *       Filename:  mysqltest.h 
 *    Description:    
 *                                                                                     
 *        Version:  1.0 
 *        Created:  2009年02月16日 16时15分20秒 
 *       Revision: 
 *       Compiler:  gcc 
 * 
 *         Author:  cyher (), cyher.net@gmail.com 
 *        Company:  cyher.NET 
 *                                                                                     
 **************************************************************************************/ 
 
#ifndef MYSQLTEST_H
#define MYSQLTEST_H
 
#define OK 0
#define ERROR -1
struct user_info {
        int ark_grp; 
        int puv_grp; 
        int level; 
        char name[25];   
        char pswd[25]; 
};
 
int init_datebase(void);
int my_insert(struct user_info * user);
 
#endif
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
**********************************************************
 *                                                                                     
 *       Filename:  mysqltest.c 
 *    Description:  mysql 
 *                                                                                     
 *        Version:  1.0 
 *        Created:  20090216151939秒 
 *       Revision: 
 *       Compiler:  gcc 
 * 
 *         Author:  cyher (), cyher.net@gmail.com 
 *        Company:  cyher.NET 
 *                                                                                     
 ***********************************************************/ 
 
#include                              /* mysql库 */ 
#include
#include
#include
#include "mysqltest.h"
 
MYSQL my_sql;
 
int init_datebase(void)
{
        my_bool on = 1; 
 
        mysql_init(&my_sql); 
 
     /* MYSQL_OPT_RECONNECT如果发现连接丢失,启动或禁止与服务器的自动再连接。从MySQL 5.0.3 
          * 开始,默认情况下禁止再连接,这是5.0.13中的新选项, 
          * 提供了一种以显式方式设置再连接行为的方法。 */ 
 
        if ( 0 != mysql_options(&my_sql, MYSQL_OPT_RECONNECT, &on)) { 
                printf( "Error set mysql_options for MYSOL_OPT_RECONNECT:%s\n", mysql_error(&my_sql) ); 
                return (OK); 
        } 
 
        if (!mysql_real_connect(&my_sql,"localhost", "root", "123456789", "Grandi_Power",0,NULL,0)) { 
                printf( "Error connecting to database: %s\n",mysql_error(&my_sql)); 
                return(ERROR); 
        } 
 
        return(OK); 
 
}
 
int my_insert(struct user_info * user)
{
 
        MYSQL_STMT *stmt; 
        MYSQL_BIND  bind[5]; 
        int user_name_len, user_pswd_len; 
 
        my_ulonglong  affected_rows; 
 
        char *sql="insert into user (USERNAME,PASSWORD,ARK_GROUP_ID,PURVIWE_GROUP_ID,LEVEL) values(?,?,?,?,?)"; 
 
        if (!(stmt = mysql_stmt_init(&my_sql))) 
                return; 
 
        memset(bind,0,sizeof(bind)); 
 
        if(mysql_stmt_prepare(stmt, sql, strlen(sql))) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        user_name_len = strlen(user->name); 
        user_pswd_len = strlen(user->pswd); 
 
        bind[0].buffer_type = MYSQL_TYPE_VAR_STRING; 
        bind[0].buffer = &(user->name); 
        bind[0].buffer_length = 25;                 /* 最大长度 */ 
        bind[0].is_null = 0; 
        bind[0].length= (unsigned long *)&user_name_len;                   /* 实际长度的地址 */ 
 
        bind[1].buffer_type = MYSQL_TYPE_VAR_STRING; 
        bind[1].buffer = &(user->pswd); 
        bind[1].buffer_length = 25;                 /* 最大长度 */ 
        bind[1].is_null = 0; 
        bind[1].length= (unsigned long *)&user_pswd_len;                   /* 实际长度的地址 */ 
 
        bind[2].buffer_type = MYSQL_TYPE_LONG; 
        bind[2].buffer = (char*)&(user->ark_grp); 
        bind[2].is_null = 0; 
        bind[2].length = 0; 
 
        bind[3].buffer_type = MYSQL_TYPE_LONG; 
        bind[3].buffer = (char*)&(user->puv_grp); 
        bind[3].is_null = 0; 
        bind[3].length = 0; 
 
        bind[4].buffer_type = MYSQL_TYPE_LONG; 
        bind[4].buffer = (char*)&(user->level); 
        bind[4].is_null= 0; 
        bind[4].length= 0; 
 
        if (mysql_stmt_bind_param(stmt, bind)) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        if (mysql_stmt_execute(stmt)) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        affected_rows = mysql_stmt_affected_rows(stmt); 
 
        if(1!=affected_rows) { 
                mysql_stmt_close(stmt); 
                return ERROR; 
        } 
 
        printf("INSERT SUCCEESFUL\n"); 
 
        mysql_stmt_close(stmt); 
}
 
int main(int argc, char **argv)
{
        struct user_info user; 
        strcpy(user.name,"haha"); 
        strcpy(user.pswd,"ninini"); 
        user.level = 4; 
        user.ark_grp = 88822; 
        user.puv_grp = 333; 
 
        init_datebase(); 
        my_insert(&user); 
 
        return OK; 
}
 
Makefile:
1
2
mytest: mysqltest.c  mysqltest.h
        gcc -o mytest mysqltest.c -I/usr/include/mysql -L/usr/lib/mysql  -lmysqlclient

相关日志

编码之外

        中国的程序员的问题,ok.也许我没有资格评论,我也是一个中国的程序员,而且是很不合格的一个.广义的程序员分三种:1.coder,2.programmer,3,architect.也就是,代码输入员,程序编写员,系统架构师.现在很清楚我想说什么了,咱们大部分人还是coder,我们要变成programmer甚至architect!但是我自己也不知道怎么变成….不过我是用c语言以及脚本语言,汇编语言的就很少牵扯architect的问题了.

       按照一个面向对象程序员的发展来说,coder->programmer->architect基本都是这样的发展了,但是毕竟还有其他的一些情况了.对于底层的呢coder->programmer->hacker or cracker.说多了,仅仅是我的观点.我写这些一定是事出有因的.今天在公司正在准备明年的项目,在做需求分析和概要设计的时候,我们几个讨论没有什么结果,就请来了一个作了十几年java的一个”老”程序员.他的到来,让我一个底层的程序员感觉到软件工程这几个字(我对软工一窍不通),分析问题井井有条,叙述解决问题的方法是清晰简洁.在公司的白板上画了一幅又一幅烂熟于心的结构,让整个讨论顺利的进行,并且达到了一个新的高度.

       在我心中他就是一个architect(确实也是),他整个讨论中很少触及代码实现,但是他的话让我觉得代码是确实整个系统的很小的一部分,尽管在实际上程序就是代码构成.真正让我感觉我现在只是个coder就是他说的:”文档的重要性”.在讨论即将结束的时候,他要求做java的那个程序员把今天讨论的结果整理一下,再用文裆把整个系统的基本结构描述一下,为我们下次的讨论做好准备.但是那个程序员愁眉苦脸,说我这两天我写文档都快写吐了,(实际上他写了8页的word),老java程序员也就是architcet告诉他:

年轻人,你知道对于一个优秀的系统,编码之外的事要比你认为的编码重要的多!没有优秀的文档支持,随之而来的就是,无尽的bug,甚至是架构上的设计失误,返工是不可避免的.编码的时间最多也就是20%的时间,更长的时间我们就是在写文档!这个写文档就是,我们现在做的需求分析,概要设计,详细设计!

然后,他就举出了几个例子,拿出了一个概要设计,在我看来那份概要设计,对我来说比详细设计还要详细,但是那只是他所谓的概要设计.他给我们讲完了以后,用ROSE给我们演示文档生成代码,这个虽然我造就知道,但是第一次看,真的很疯狂!真的让我明白在面向对象程序里面,编码之外的架构师为什么有那么高的身价,而我们这些coder为什么被称为IT民工了.当然我是做底层的,我的不会去管java的事,但是由这段谈话,我真正理解了编码之外的事情!大家想想看,在我们编程的时候,是否为我们快速完成了一项功能而欣喜,但我们欣喜的代价就是处理bug的痛苦.真心希望中国和我一样的初级coder们能够完善自己的文档,完善自己的思想.程序是衣,算法是魂,那么架构就是(我还没想好)…

相关日志

linux环境编程之进程间通信(消息队列)

/**************************************************************
* name : server.c                          *
* author : cyher                          *
* date : 2008-8-6                          *
* description : 服务端进程向消息队列里面放消息传给客户端     *
**************************************************************/
#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
#include <time.h>

struct msgbuf/*消息队列结构*/
{
long mtype;
char mtext[256];
};

int
init_daemon(void);/*守护进程启动函数*/

int
main()
{
key_t key;
int msgid;
char *p;
time_t t;
struct msgbuf msg= {100,”"};/*设置消息的id为100*/
key = ftok(“/home/cyher/workspace/c/star”,’s');/*产生一个key*/
msgid = msgget(key,IPC_CREAT | 0666);/*产生一个ipc标识*/
if(msgid == -1)
{
perror(“msgget”);
exit(1);
}

init_daemon();/*守护进程创建*/
while(1)/*进入循环执行*/
{
t = time(NULL);
p = asctime(localtime(&t));
strcpy(msg.mtext,p);/*把时间字符放入msg.mtext*/
msgsnd(msgid,&msg,strlen(msg.mtext)+1,IPC_NOWAIT);/*放入消息队列无阻塞*/
sleep(2);
}

}

/**************************************************************
* name : client.c                          *
* author : cyher                          *
* date : 2008-8-6                          *
* description : 客户端进程从消息队列里面取消息打印到屏幕上   *
**************************************************************/
#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <string.h>
#include <time.h>

struct msgbuf
{
long mtype;
char mtext[256];
};

int
main()
{
key_t key;
int msgid;
struct msgbuf msg;
key = ftok(“/home/cyher/workspace/c/star”,’s');
msgid = msgget(key,IPC_CREAT | 0666);
if(msgid == -1)
{
perror(“msgget”);
exit(1);
}

while(1)
{
if(msgrcv(msgid,&msg,256,100,IPC_NOWAIT) == -1)
{
perror(“msgrcv:”);
}
printf(“%s”,msg.mtext);
memset(&msg,0,sizeof(struct msgbuf));
sleep(2);
}

}

/*******************************
* name:init_daemon.c
* author:cyher
* date:2008-8-1
* description:initialize a daemon process
* */

#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <stdlib.h>

int
init_daemon()
{
int pid;
int i;
if( (pid=fork())<0 )
{
perror(“fork”);
exit(1);
}
else if(pid > 0) //是父进程就退出
{
exit(0);
}

if((pid=fork()) < 0)
{
perror(“fork2″);
exit(1);
}
else if (pid > 0)//是第一子进程也退出
{
exit(0);
}
//
//下面都是第二子进程运行
sleep(2);
setsid();//使子进程脱离父进程的关系,把父进程的信息改掉
//脱离终端的控制
//
for(i=0;i<1024;i++)//关闭文件描述符,节省资源
close(i);
chdir(“/tmp”);//改变工作目录
umask(0);//重设掩码,使程序工作顺畅

return 0;

}

相关日志

linux环境编程进程间通信(共享内存)

/*****************************************
* name : shm_a.c
* author : cyher
* date : 2008-8-6
* description : 进程a,共享内存通信
*****************************************/
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>

int
main()
{
int oflag,id;
char *ptr;
char buf[512];
size_t length=512;
time_t t;

oflag = 0644|IPC_CREAT;
id = shmget(ftok(“/home/cyher/workspace/c/star”,89),length,oflag);
if((ptr = shmat(id,NULL,0)) == (void *) -1)
{
perror(“shmat”);
exit(1);

}
while(1)
{
t=time(NULL);
memset(buf,0,512);
memcpy(buf,ptr,512);
printf(“%s”,buf);
sprintf(ptr,”time: %s pid: [%d]\n”,asctime(localtime(&t)),getpid());
sleep(5);
}
}

/*****************************************
* name : shm_b.c
* author : cyher
* date : 2008-8-6
* description : 进程b,共享内存通信
*****************************************/

#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <unistd.h>

int
main()
{
int oflag,id;
char *ptr;
char buf[512];
size_t length=512;
time_t t;

oflag = 0644|IPC_CREAT;
id = shmget(ftok(“/home/cyher/workspace/c/star”,89),length,oflag);
if((ptr = shmat(id,NULL,0)) == (void *) -1)
{
perror(“shmat”);
exit(1);

}
while(1)
{
sleep(5);
t=time(NULL);
memset(buf,0,512);
memcpy(buf,ptr,512);
printf(“%s”,buf);
sprintf(ptr,”time: %s pid: [%d]\n”,asctime(localtime(&t)),getpid());
}
}

相关日志