Chinaunix

标题: 编写过PHP模块的朋友请进来指导一下! [打印本页]

---

作者: maya1982    时间: 2007-03-02 12:51
标题: 编写过PHP模块的朋友请进来指导一下!
系统信息：
Debian Etch (Kernel 2.6.18-3-686 )
5.0.32-Debian_3-log Debian etch distribution
PHP 5.2.0-8

问题：用php 源代码树下的ext_skel 创建了一个新的模块基本骨架。添加了一个模块函数。在php脚本中调用
sample_passport函数，没有任何输出。

原来的连接数据库的代码工作正常。我想把数据库的代码放到php模块函数中。

mysql代码：

query.h

1. 
   
2. // system header files
   
3. #include <stdio.h>
   
4. #include <stdlib.h>
   
5. #include <unistd.h>
   
6. // mysql header files
   
7. #include <my_global.h>
   
8. #include <my_sys.h>
   
9. #include <mysql.h>
   
10. 
    
11. 
    
12. static void print_error(MYSQL *mysql, char *message);
    

复制代码

query.c

1. 
   
2. /*
   
3. *  shell> gcc -o firstquery firstquery.c -lmysqlclient
   
4. */
   
5. #include "firstquery.h"
   
6. 
   
7. static void print_error(MYSQL *mysql, char *message)
   
8. {
   
9.     fprintf (stderr, "%s\n", message);
   
10.     if (mysql != NULL)
    
11.     {
    
12. #if MYSQL_VERSION_ID >= 40101
    
13.           fprintf(stderr,"MYSQL ERROR:[ERRNO] %u [SQLSTATE] %s [MESSAGE] %s\n",
    
14.                   mysql_errno(mysql), mysql_error(mysql),mysql_sqlstate(mysql));
    
15. #else
    
16.           fprintf(stderr,"MYSQL ERROR:[ERRNO] %u [MESSAGE] %s\n",
    
17.                   mysql_errno(mysql), mysql_error(mysql));
    
18. #endif
    
19.     }
    
20. }
    
21. 
    
22. 
    
23. int main(int argc, char *argv[]) {
    
24.        
    
25.         /* MYSQL DATA TYPES*/
    
26.         MYSQL mysql;
    
27.         MYSQL_RES *result;
    
28.         MYSQL_ROW row;
    
29.         MYSQL_FIELD *fields;
    
30.        
    
31.         /* VARIABLES */
    
32.         unsigned int numrows, numcols, i;
    
33.        
    
34.         /* init connection data structure
    
35.                   conn = mysql_init (NULL);
    
36.             if (conn == NULL)
    
37.             {
    
38.                 fprintf (stderr, "mysql_init() failed (probably out of memory)\n");
    
39.                 exit (1);
    
40.             }
    
41.     */
    
42.         mysql_init(&mysql);        //        init connection data structure  protoype: MYSQL *mysql_init(MYSQL *mysql)
    
43.         if(&mysql == NULL){
    
44.         fprintf (stderr, "mysql_init() failed (probably out of memory)\n");
    
45.         exit(EXIT_FAILURE);
    
46.         }
    
47.         /* Establish a database connection
    
48.           
    
49.           MYSQL *mysql_real_connect(
    
50.                           MYSQL *mysql,
    
51.                           const char *host,
    
52.                           const char *user,
    
53.                           const char *passwd,
    
54.                           const char *db,
    
55.                           unsigned int port,
    
56.                           const char *unix_socket,
    
57.                           unsigned long client_flag                                  // CLIENT_COMPRESS | CLIENT_FOUND_ROWS |CLIENT_IGNORE_SPACE
    
58.                                                                  // | CLIENT_INTERACTIVE | CLIENT_LOCAL_FILES
    
59.                                                                  // | CLIENT_MULTI_STATEMENTS
    
60.                                                                  // | CLIENT_MULTI_RESULTS | CLIENT_NO_SCHEMA
    
61.                                                                  // | CLIENT_ODBC | CLIENT_SSL
    
62.           )
    
63.          */
    
64.          
    
65.         if (!mysql_real_connect(
    
66.                              &mysql,                             // connect handle
    
67.                              "localhost",                        // hostname
    
68.                              "develop",                             // mysql username
    
69.                              "**********",              // password
    
70.                              "passport",                         // database name
    
71.                              3306,                               // port
    
72.                              "/var/run/mysqld/mysqld.sock",      // unix socket
    
73.                              0)                                 
    
74.         ){
    
75.           print_error(&mysql,"mysql_real_connect():Can not connect to mysql database");
    
76.           mysql_close(&mysql);
    
77.           exit(EXIT_FAILURE);
    
78.         }
    
79.         /* Execute a query */
    
80.         /*char query[] = "SELECT book_id, cond, title FROM book";*/
    
81.         char query[] = "SELECT username,usertypeid,email,status,ipaddr_registered FROM passport";
    
82.         if (mysql_query(&mysql, query) != 0)
    
83.         {
    
84.           print_error(&mysql,"mysql_query():failed query to database");
    
85.           mysql_close(&mysql);
    
86.           exit(EXIT_FAILURE);
    
87.         }
    
88.         /* Assign the result handle */
    
89.         result = mysql_use_result(&mysql);
    
90.         if (!result){
    
91.           print_error(&mysql,"mysql_use_result():Can not get the result set");
    
92.           mysql_close(&mysql);
    
93.           exit(EXIT_FAILURE);
    
94.         }
    
95.         /* Find the number of columns in the result */
    
96.         numcols = mysql_num_fields(result);
    
97.         fields = mysql_fetch_fields(result);
    
98.         /* Loop through the result set to display it */
    
99.         printf("\n");
    
100.         printf("----------------------------------------------------------------------\n");
     
101.         for(i = 0; i < numcols; i++){
     
102.            printf("%s\t",fields[i].name);
     
103.         }
     
104.         printf("\n");
     
105.         while (row = mysql_fetch_row(result)) {
     
106. 
     
107.                 for(i=0; i < numcols; i++) {
     
108.                         printf("%s\t", row[i]);
     
109.                 }
     
110.                 printf("\n");
     
111.         }
     
112.         printf("\n");
     
113.        
     
114.         exit(EXIT_SUCCESS);
     
115. }
     
116. 
     

复制代码

php代码：

php_sample.h

1. 
   
2. #ifndef PHP_SAMPLE_H
   
3. /* Prevent double inclusion */
   
4. #define PHP_SAMPLE_H
   
5. /* Define Extension Properties
   
6. * 定义扩展属性,名称和版本号
   
7. */
   
8. #define PHP_SAMPLE_EXTNAME    "sample"
   
9. #define PHP_SAMPLE_EXTVER      "1.0"
   
10. /*
    
11. * Import configure options when building outside of the PHP source tree
    
12. * 在php源代码树外构建时导入配置选项
    
13. */
    
14. #ifdef HAVE_CONFIG_H
    
15. #include "config.h"
    
16. #endif
    
17. /* Include PHP Standard Header
    
18. * 包含php标准头文件
    
19. */
    
20. #include "php.h"
    
21. /* Define the entry point symbol
    
22. * Zend will use when loading this module
    
23. * 定义入口点符号,Zend将在加载此模块时使用
    
24. */
    
25. extern zend_module_entry sample_module_entry;
    
26. #define phpext_sample_ptr &sample_module_entry
    
27. 
    
28. /* 本模块在phpinfo() 用户空间函数输出函数的原型定义 */
    
29. static ZEND_MINFO_FUNCTION(sample);
    
30. 
    
31. /* 模块(扩展)函数原型声明 */
    
32. ZEND_FUNCTION(sample_long);
    
33. ZEND_FUNCTION(sample_hello_world);
    
34. ZEND_FUNCTION(sample_array_range);
    
35. ZEND_FUNCTION(sample_hello_greeting);
    
36. ZEND_FUNCTION(sample_hello_optional);
    
37. ZEND_FUNCTION(sample_onearg);
    
38. ZEND_FUNCTION(sample_getlong);
    
39. ZEND_FUNCTION(sample_variable_arguments);
    
40. ZEND_FUNCTION(sample_var_dump);
    
41. ZEND_FUNCTION(sample_return_array);
    
42. ZEND_FUNCTION(sample_array);
    
43. ZEND_FUNCTION(sample_array_passport);
    
44. ZEND_FUNCTION(sample_passport);
    
45. 
    
46. 
    
47. #if (PHP_MAJOR_VERSION > 5) || (PHP_MAJOR_VERSION == 5 && PHP_MINOR_VERSION > 0)
    
48. ZEND_FUNCTION(sample_reference_a);
    
49. static
    
50.     ZEND_BEGIN_ARG_INFO_EX(php_sample_retref_arginfo, 0, 1, 0)
    
51.     ZEND_END_ARG_INFO ()
    
52.    
    
53. #endif /* PHP >= 5.1.0 */
    
54. 
    
55. #endif /* PHP_SAMPLE_H */
    
56. 
    
57. #include <my_global.h>
    
58. #include <my_sys.h>
    
59. #include <mysql.h>
    
60. 
    
61. 
    
62. static void print_error(MYSQL *mysql, char *message);
    
63. 
    

复制代码

sample.c

1. 
   
2. #include "php_sample.h"
   
3. 
   
4. static function_entry php_sample_functions[] = {
   
5.         ZEND_FE(sample_long, NULL)
   
6.     ZEND_FE(sample_hello_world, NULL)
   
7.     ZEND_FE(sample_hello_greeting, NULL)
   
8.     ZEND_FE(sample_hello_optional, NULL)
   
9.     ZEND_FE(sample_array_range, NULL)
   
10.     ZEND_FE(sample_onearg, NULL)
    
11.         ZEND_FE(sample_getlong, NULL)
    
12.         ZEND_FE(sample_variable_arguments, NULL)
    
13.         ZEND_FE(sample_var_dump, NULL)
    
14.         ZEND_FE(sample_return_array, NULL)
    
15.         ZEND_FE(sample_array, NULL)
    
16.         ZEND_FE(sample_array_passport, NULL)
    
17.         ZEND_FE(sample_passport, NULL)
    
18.     { NULL, NULL, NULL }
    
19. };
    
20. 
    
21. zend_module_entry sample_module_entry = {
    
22. #if ZEND_MODULE_API_NO >= 20010901
    
23.      STANDARD_MODULE_HEADER,
    
24. #endif
    
25.     PHP_SAMPLE_EXTNAME,
    
26.     php_sample_functions,
    
27.     NULL,
    
28.     NULL,
    
29.     NULL,
    
30.     NULL,
    
31.     NULL,
    
32. #if ZEND_MODULE_API_NO >= 20010901
    
33.     PHP_SAMPLE_EXTVER,
    
34. #endif
    
35.     STANDARD_MODULE_PROPERTIES
    
36. };
    
37. #ifdef COMPILE_DL_SAMPLE
    
38. ZEND_GET_MODULE(sample)
    
39. #endif
    
40. 
    
41. 
    
42. ZEND_FUNCTION(sample_long)
    
43. {
    
44.     ZVAL_LONG(return_value, 42);
    
45.     return;
    
46. }
    
47. ZEND_FUNCTION(sample_hello_world)
    
48. {
    
49.        
    
50.         char *name;
    
51.     int name_len;
    
52. 
    
53. 
    
54.     if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s", &name, &name_len) == FAILURE) {
    
55.         RETURN_NULL();
    
56.     }
    
57.     php_printf("Hello ");
    
58.     PHPWRITE(name, name_len);
    
59.     php_printf("!<br/>");
    
60.        
    
61. //        ZVAL_STRING(return_value, "<br/>Hello World!<br/>",1);
    
62. //        return;
    
63. }
    
64. 
    
65. /*
    
66. 
    
67. function sample_hello_world($name, $greeting) {
    
68.         echo "Hello $greeting $name!\n";
    
69. }
    
70. sample_hello_world('John Smith', 'Mr.');
    
71. 
    
72. */
    
73. ZEND_FUNCTION(sample_hello_greeting)
    
74. {
    
75.     if(ZEND_NUM_ARGS() != 2){
    
76.             WRONG_PARAM_COUNT;
    
77.     }       
    
78.     char *name;
    
79.     int name_len;
    
80.     char *greeting;
    
81.     int greeting_len;
    
82.     if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "ss",&name, &name_len, &greeting, &greeting_len) == FAILURE) {
    
83.         RETURN_NULL();
    
84.     }
    
85.     php_printf("Hello ");
    
86.     PHPWRITE(greeting, greeting_len);
    
87.     php_printf(" ");
    
88.     PHPWRITE(name, name_len);
    
89.     php_printf("!\n");
    
90. }
    
91. // 解析可选参数
    
92. /*function sample_hello_world($name, $greeting='Mr./Ms.') {
    
93.     echo "Hello $greeting $name!\n";
    
94. }
    
95. sample_hello_world('Ginger Rogers','Ms.');
    
96. sample_hello_world('Fred Astaire');*/
    
97. ZEND_FUNCTION(sample_hello_optional)
    
98. {
    
99.     if(ZEND_NUM_ARGS() < 1 || ZEND_NUM_ARGS() > 2){
    
100.             WRONG_PARAM_COUNT;
     
101.     }
     
102.         char *name;
     
103.     int name_len;
     
104.     char *greeting = "Mr./Mrs.";
     
105.     int greeting_len = sizeof("Mr./Mrs.") - 1;
     
106.    
     
107.     if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC, "s|s",&name, &name_len, &greeting, &greeting_len) == FAILURE) {
     
108.         RETURN_NULL();
     
109.     }
     
110.     php_printf("Hello ");
     
111.     PHPWRITE(greeting, greeting_len);
     
112.     php_printf(" ");
     
113.     PHPWRITE(name, name_len);
     
114.     php_printf("!\n");
     
115. 
     
116. }
     
117. ZEND_FUNCTION(sample_array_range)
     
118. {
     
119.     if (return_value_used) {
     
120.         int i;
     
121.         array_init(return_value);
     
122.         for(i = 0; i < 1000; i++) {
     
123.             add_next_index_long(return_value, i);
     
124.         }
     
125.         return;
     
126.     } else {
     
127.         php_error_docref(NULL TSRMLS_CC, E_NOTICE,"Static return-only function called without processing output");
     
128.         RETURN_NULL();
     
129.     }
     
130. }
     
131. ZEND_FUNCTION(sample_onearg)
     
132. {
     
133.     zval *firstarg;
     
134.     if (zend_get_parameters(ZEND_NUM_ARGS(), 1, &firstarg) == FAILURE) {
     
135.         php_error_docref(NULL TSRMLS_CC, E_WARNING,"Expected at least 1 parameter.");
     
136.         RETURN_NULL();
     
137.     }
     
138. }
     
139. ZEND_FUNCTION(sample_getlong)
     
140. {
     
141.         long foo;
     
142.     if (zend_parse_parameters(ZEND_NUM_ARGS() TSRMLS_CC,
     
143.                          "l", &foo) == FAILURE) {
     
144.         RETURN_NULL();
     
145.     }
     
146.     php_printf("The integer value of the parameter you "
     
147.              "passed is: %ld\n", foo);
     
148.     RETURN_TRUE;
     
149. 
     
150. }
     
151. ZEND_FUNCTION(sample_variable_arguments)
     
152. {
     
153. 
     
154. }
     
155. ZEND_FUNCTION(sample_var_dump)
     
156. {
     
157.     int i, argc = ZEND_NUM_ARGS();
     
158.     zval ***args;
     
159. 
     
160. 
     
161.     args = (zval ***)safe_emalloc(argc, sizeof(zval **), 0);
     
162.     if (ZEND_NUM_ARGS() == 0 ||
     
163.         zend_get_parameters_array_ex(argc, args) == FAILURE) {
     
164.         efree(args);
     
165.         WRONG_PARAM_COUNT;
     
166.     }
     
167.     for (i=0; i<argc; i++) {
     
168.         php_var_dump(args[i], 1 TSRMLS_CC);
     
169.     }
     
170.     efree(args);
     
171. }
     
172. //ZEND_FUNCTION(sample_arg_fullnull)
     
173. //{
     
174. //}
     
175. //ZEND_FUNCTION(sample_arg_nullok)
     
176. //{
     
177. //}
     
178. 
     
179. ZEND_FUNCTION(sample_return_array)
     
180. {
     
181.         zval *my_long;
     
182.         // Declaring and allocating return_value to be an array
     
183.         array_init(return_value);
     
184.         //Creates and assign the long element at (long)42
     
185.         MAKE_STD_ZVAL(my_long);
     
186.         ZVAL_LONG(my_long, 42);
     
187.         //Make this our $array[0] I do not use add_index_long to
     
188.         //to show a "by-hand" assignation
     
189.         zend_hash_index_update(HASH_OF(return_value), 0, (void *)&my_long, sizeof(zval *), NULL);
     
190.         //Returns nothing to satisfy the void prototype
     
191.         return ;
     
192. }
     
193. //ZEND_FUNCTION(sample_return_object){}
     
194. 
     
195. ZEND_FUNCTION(sample_array)
     
196. {
     
197.     zval *subarray;
     
198. 
     
199.     array_init(return_value);
     
200.     /* Add some scalars */
     
201.     add_assoc_long(return_value, "life", 42);
     
202.     add_index_bool(return_value, 123, 1);
     
203.     add_next_index_double(return_value, 3.1415926535);
     
204.     /* Toss in a static string, dup'd by PHP */
     
205.     add_next_index_string(return_value, "Foo", 1);
     
206.     /* Now a manually dup'd string */
     
207.     add_next_index_string(return_value, estrdup("Bar"), 0);
     
208. 
     
209.     /* Create a subarray */
     
210.     MAKE_STD_ZVAL(subarray);
     
211.     array_init(subarray);
     
212.     /* Populate it with some numbers */
     
213.     add_next_index_long(subarray, 1);
     
214.     add_next_index_long(subarray, 20);
     
215.     add_next_index_long(subarray, 300);
     
216.     add_next_index_long(subarray, 1);
     
217.     /* Place the subarray in the parent */
     
218.     add_index_zval(return_value, 444, subarray);
     
219. }
     
220. ZEND_FUNCTION(sample_array_passport){
     
221.         array_init(return_value);
     
222.         add_assoc_long(return_value, "passport_id", 1);
     
223.         add_assoc_string(return_value, "passport_name", "hezhiqiang", 1);
     
224.         add_assoc_string(return_value, "passport_email", "developerworks@163.com", 1);       
     
225. }
     
226. ZEND_FUNCTION(sample_passport){
     
227.         MYSQL mysql;
     
228.         MYSQL_RES *result;
     
229.         MYSQL_ROW row;
     
230.         MYSQL_FIELD *fields;       
     
231.         unsigned int numrows, numcols, i;
     
232.        
     
233. //        zval *rrow;
     
234. //        MAKE_STD_ZVAL(rrow);
     
235. //        array_init(return_value);
     
236. //        array_init(rrow);
     
237.        
     
238.         mysql_init(&mysql);        //        init connection data structure  protoype: MYSQL *mysql_init(MYSQL *mysql)
     
239.         if(&mysql == NULL){
     
240.         fprintf (stderr, "mysql_init() failed (probably out of memory)\n");
     
241.         exit(EXIT_FAILURE);
     
242.         }
     
243.         if (!mysql_real_connect(
     
244.                              &mysql,                             // connect handle
     
245.                              "localhost",                        // hostname
     
246.                              "develop",                             // mysql username
     
247.                              "**********",              // password
     
248.                              "passport1",                         // database name
     
249.                              3306,                               // port
     
250.                              "/var/run/mysqld/mysqld.sock",      // unix socket
     
251.                              0)                                 
     
252.         ){
     
253.           print_error(&mysql,"mysql_real_connect():Can not connect to mysql database");
     
254.           mysql_close(&mysql);
     
255.           exit(EXIT_FAILURE);
     
256.         }
     
257.         /* Execute a query */
     
258.         char query[] = "SELECT passportid,username,usertypeid,email,status,ipaddr_registered FROM passport WHERE passportid = 1";
     
259.         if (mysql_query(&mysql, query))
     
260.         {
     
261.           print_error(&mysql,"mysql_query():failed query to database");
     
262.           mysql_close(&mysql);
     
263.           exit(EXIT_FAILURE);
     
264.         }
     
265.         result = mysql_use_result(&mysql);  // get result set
     
266.         if (!result){
     
267.           print_error(&mysql,"mysql_use_result():Can not get the result set");
     
268.           mysql_close(&mysql);
     
269.           exit(EXIT_FAILURE);
     
270.         }
     
271.         numcols = mysql_num_fields(result); // get the number of columns in the result
     
272.         fields = mysql_fetch_fields(result);   // get fields infomation
     
273. //        for(i = 0; i < numcols; i++){
     
274. //           printf("%s\t",fields[i].name);        // print field name
     
275. //        }
     
276. //        while (row = mysql_fetch_row(result)) {
     
277. //                int j = 0;
     
278. //                for(i=0; i < numcols; i++) {
     
279. //                        printf("%s\t", row[i]);
     
280. //                        add_assoc_string(rrow,fields[i].name,row[i],1);
     
281. //                }
     
282. //                add_index_zval(return_value, j, rrow);
     
283. //                j++;
     
284. //        }
     
285. 
     
286.         /* Loop through the result set to display it */
     
287.         printf("\n");
     
288.         printf("----------------------------------------------------------------------\n");
     
289.         for(i = 0; i < numcols; i++){
     
290.            printf("%s\t",fields[i].name);
     
291.         }
     
292.         printf("\n");
     
293.         while (row = mysql_fetch_row(result)) {
     
294.                 for(i=0; i < numcols; i++) {
     
295.                         printf("%s\t", row[i]);
     
296.                 }
     
297.                 printf("\n");
     
298.         }
     
299.         printf("\n");
     
300. 
     
301. 
     
302. 
     
303. }
     
304. 
     
305. static void print_error(MYSQL *mysql, char *message)
     
306. {
     
307.     fprintf (stderr, "%s\n", message);
     
308.     if (mysql != NULL)
     
309.     {
     
310. #if MYSQL_VERSION_ID >= 40101
     
311.           fprintf(stderr,"MYSQL ERROR:[ERRNO] %u [SQLSTATE] %s [MESSAGE] %s\n",
     
312.                   mysql_errno(mysql), mysql_error(mysql),mysql_sqlstate(mysql));
     
313. #else
     
314.           fprintf(stderr,"MYSQL ERROR:[ERRNO] %u [MESSAGE] %s\n",
     
315.                   mysql_errno(mysql), mysql_error(mysql));
     
316. #endif
     
317.     }
     
318. }
     
319. 
     

复制代码

[ 本帖最后由 maya1982 于 2007-3-4 13:22 编辑 ]

---

作者: maya1982    时间: 2007-03-04 15:34
怎么没有人回答一些呢？

---

作者: Neil    时间: 2007-03-04 17:32
我前段时间整理的一些文字，希望对你能有些帮助

http://bbs.nettf.net/forums/index.php?showtopic=60320

---

作者: maya1982    时间: 2007-03-04 18:53
虽然没有我需要的，但是还是感谢你的关注，我大概是知道问题出在什么地方了。
我在代码中直接使用了MYSQL数据类型，但是在Zend中数据库连接是作为资源类型使用的对资源数据类型的变量要求作特殊的处理，我直接使用了声明的
MYSQL mysql;
连接数据库肯定就没有任何输出了，虽然编译没有任何错误。

---

作者: Neil    时间: 2007-03-04 22:48
你可以把原来的数据库连接的代码编译成动态库，然后在php模块里面用函数指针调用
这个方法我试过，比把原来的动态库在php模块里面重新实现要简单许多
另外，如果你实在想重新实现的话，建议参看php的ext目录下的mysq目录下的l源码

---

作者: maya1982    时间: 2007-03-05 11:06
还有，我能直接在C api层次上直接调用ext/mysql提供的api函数？

---

作者: Neil    时间: 2007-03-05 21:00
那你不如直接调用mysql提供的 C API了

---

作者: maya1982    时间: 2007-03-06 15:28
我研究了两天还是不能成功，望提供一些代码来研究一下。
在php模块中调用mysql api 总是没有输出。不知道问题出在什么地方。。

---

作者: netkiller    时间: 2007-03-06 18:35
关注,我也想这么搞

---

作者: Neil    时间: 2007-03-06 23:26
下面是我程序里的部分代码，是调用我自己的一个工程用DLL的，懒得在php的模块里面重写了（要考虑一堆的内存分配、多线程等，不想折腾了），用函数指针调用的

.h 文件中：

1. 
   
2. //long __stdcall nsms_ctrl_SendMsg( const char * ump, const char * msg )
   
3. typedef long (__stdcall * pFunSendMsg)( const char *, const char * );
   
4. pFunSendMsg funSendMsg;
   

复制代码

.c 文件中：

1. 
   
2. /* {{{ proto long nsms_ext_init( void )
   
3.    Return long to test that the module is init done. */
   
4. PHP_FUNCTION(nsms_ext_init)
   
5. {
   
6.         long lngRet = 1;
   
7.        
   
8.         hNsmsCtrl = LoadLibrary( "nsms_ctrl.dll" );
   
9.         if( hNsmsCtrl ) {
   
10.                 funSendMsg = (pFunSendMsg)GetProcAddress( hNsmsCtrl, "nsms_ctrl_SendMsg" );
    
11.                 if( funSendMsg ) {
    
12.                         lngRet = 0;
    
13.                 } else {
    
14.                         lngRet = 3;
    
15.                 }
    
16.         } else {
    
17.                 lngRet = 2;
    
18.         }
    
19. 
    
20.         RETURN_LONG( lngRet );
    
21. }
    
22. /* }}} */
    
23. 
    
24. /* {{{ proto long nsms_ext_release( void )
    
25.    Return long to test that the module is init done. */
    
26. PHP_FUNCTION(nsms_ext_release)
    
27. {
    
28.         long lngRet = 4;
    
29.        
    
30.         if( hNsmsCtrl ) {
    
31.                 lngRet = ( FreeLibrary( hNsmsCtrl ) > 0 ) ? 0 : 4;
    
32.                 hNsmsCtrl = NULL;
    
33.         } else {
    
34.                 lngRet = 0;
    
35.         }
    
36. 
    
37.         RETURN_LONG( lngRet );
    
38. }
    
39. /* }}} */
    
40. 
    
41. /* {{{ proto long nsms_ext_send(string mp, string msg)
    
42.     */
    
43. PHP_FUNCTION(nsms_ext_send)
    
44. {
    
45.     char *mp = NULL;
    
46.     char *msg = NULL;
    
47.     int argc = ZEND_NUM_ARGS();
    
48.     int mp_len;
    
49.     int msg_len;
    
50. 
    
51.         long lngPort = -1;
    
52.         long lngRet = ERR_UNKNOWN;
    
53. 
    
54.     if (zend_parse_parameters(argc TSRMLS_CC, "ss", &mp, &mp_len, &msg, &msg_len) == FAILURE)
    
55.                 RETURN_LONG( ERR_PARAMETERS );
    
56. 
    
57.         //char * szTmp = estrdup( NSMS_EXT_G(com_port) );
    
58. 
    
59.         if( ! stricmp( NSMS_EXT_G(com_port), "COM1" ) ) {
    
60.                 lngPort = 0;
    
61.         } else if( ! stricmp( NSMS_EXT_G(com_port), "COM2" ) ) {
    
62.                 lngPort = 1;
    
63.         } else if( ! stricmp( NSMS_EXT_G(com_port), "COM3" ) ) {
    
64.                 lngPort = 2;
    
65.         } else if( ! stricmp( NSMS_EXT_G(com_port), "COM4" ) ) {
    
66.                 lngPort = 3;
    
67.         } else {
    
68.                 RETURN_LONG( ERR_COM_PORT );
    
69.         }
    
70. 
    
71.         if( funSendMsg ) {
    
72.                 lngRet = funSendMsg( mp, msg );
    
73.         } else {
    
74.                 lngRet = ERR_BASE;
    
75.         }
    
76. 
    
77.     RETURN_LONG( lngRet );
    
78. }
    
79. /* }}} */
    

复制代码

其中函数 nsms_ctrl_SendMsg 就是在DLL里面exports出来的__stdcall函数
原型就是在头文件里面注释的那个
//long __stdcall nsms_ctrl_SendMsg( const char * ump, const char * msg )

希望对你能有帮助

Good Luck

---

作者: maya1982    时间: 2007-03-07 13:28
这里是我这几天来研究PHP扩展的一些体会，和解决掉的错误

1. 
   
2. PHP_FUNCTION(passport_register){
   
3. 
   
4.         // 和之前的代码比较，我没有为*connection分配内存，显然，内存是由Zend进行管理的。必须用Zend的内存管理函数来分配和回收内存资源。
   
5.         MYSQL *connection = (MYSQL*)emalloc(sizeof(MYSQL));
   
6.         MYSQL_RES *resultset = (MYSQL_RES*)emalloc(sizeof(MYSQL_RES));
   
7. //        MYSQL_ROW row = (MYSQL_ROW)emalloc(sizeof(MYSQL_ROW));
   
8. //        MYSQL_FIELD *fields = (MYSQL_FIELD*)emalloc(sizeof(MYSQL_FIELD));
   
9. 
   
10.         unsigned int numrows, numcols, i;
    
11.         mysql_init(connection);       
    
12.         if(connection == NULL){
    
13.         RETURN_FALSE;
    
14.         }
    
15.         if (mysql_real_connect(connection,"localhost","develop","********","passport",3306,NULL,0) == NULL){
    
16.         RETURN_FALSE;
    
17.         }
    
18.         zval *rconn;
    
19.         MAKE_STD_ZVAL(rconn);
    
20. 
    
21.         // 要注册资源类型。之前却没有注册。
    
22.         ZEND_REGISTER_RESOURCE(rconn, connection, le_sample_connection);
    
23.         array_init(return_value);
    
24.         add_index_zval(return_value, 0, rconn);
    
25.        
    
26.         char query[] = "SELECT username,usertypeid,email,status,ipaddr_registered FROM passport";
    
27.         // 要在此使用资源数据类型，要从Zend内部的HashTable 中取回资源。
    
28.         ZEND_FETCH_RESOURCE(connection, MYSQL*, &rconn, -1, "mysql connection", le_sample_connection);
    
29.        
    
30.         if (mysql_query(connection, query) != 0)
    
31.         {
    
32.                 RETURN_FALSE;
    
33.         }
    
34.         resultset = mysql_use_result(connection);
    
35.         if (resultset == NULL){
    
36.                 RETURN_FALSE;
    
37.         }
    
38.         zval *rresult;
    
39.         MAKE_STD_ZVAL(rresult);
    
40.         ZEND_REGISTER_RESOURCE(rresult, resultset, le_sample_result);
    
41.         add_index_zval(return_value, 2, rresult);
    
42.        
    
43. }
    
44. 
    

复制代码

php 测试代码：

1. 
   
2. $passport = passport_register();
   
3. var_dump($passport);
   

复制代码

输出结果：

1. 
   
2. array(2) {
   
3.   [0]=>
   
4.   resource(3) of type (mysql connection)
   
5.   [2]=>
   
6.   resource(4) of type (mysql result)
   
7. }
   

复制代码

---

作者: Neil    时间: 2007-03-07 13:44
Congratulations

---

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)

Powered by Discuz! X3.2