采用curl库在PHP程序之间传递数组[原创]

[文章作者：张宴 本文版本：v1.1 最后修改：2007.08.23 转载请注明出处： http://blog.s135.com]

最近在工作中遇到一个问题：a.php程序需要将接收到的数据同时写到“线上运行的正式数据库”和“进行开发调试的测试数据库”。而测试数据库可能经常 会面临对表结构、字段、配置信息做调整等问题，很不稳定，发生错误的概率很高，如果用a.php程序同时写“正式数据库”和“测试数据库”，势必影响到线 上运行的正式服务。

于是，我想到用PHP curl扩展库将生成的$data数组post传递一份给b.php程序，然后a.php程序继续往下执行写“正式数据库”的代码。a.php程序 将$data数组传递给b.php程序就完事了，至于b.php如何处理，就不关a.php的事了，b.php程序即使写“测试数据库”失败，也不会对 a.php程序造成影响。

按照这种思路，我写了a.php和b.php的代码：

a.php程序源代码：

view plain print ?

2. $data[“username”]=“张宴”;
3. $data[“password”]=“不知 道”;
4. $data[“ip”]=“192.168.0.18”;
5. //register_shutdown_function(“post_data”, $data);
6. //function post_data($data)
7. //{
8. $curl = new Curl_Class();
9. $post = @$curl->post(“http://127.0.0.1/b.php”, $data);//这里是b.php的访问地址，请自行修改
10. //}
11. //curl类
12. class Curl_Class
13. {
14. function Curl_Class()
15. {
16. return true;
17. }
18. function execute($method, $url, $fields = ”, $userAgent = ”, $httpHeaders = ”, $username = ”, $password = ”)
19. {
20. $ch = Curl_Class::create();
21. if (false === $ch)
22. {
23. return false;
24. }
25. if (is_string($url) && strlen($url))
26. {
27. $ret = curl_setopt($ch, CURLOPT_URL, $url);
28. }
29. else
30. {
31. return false;
32. }
33. //是否显示头部信息
34. curl_setopt($ch, CURLOPT_HEADER, false);
35. //
36. curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
37. if ($username != ”)
38. {
39. curl_setopt($ch, CURLOPT_USERPWD, $username . ‘:’ . $password);
40. }
41. $method = strtolower($method);
42. if (‘post’ == $method)
43. {
44. curl_setopt($ch, CURLOPT_POST, true);
45. if (is_array($fields))
46. {
47. $sets = array();
48. foreach ($fields AS $key => $val)
49. {
50. $sets[] = $key . ‘=’ . urlencode($val);
51. }
52. $fields = implode(‘&’,$sets);
53. }
54. curl_setopt($ch, CURLOPT_POSTFIELDS, $fields);
55. }
56. elseif (‘put’ == $method)
57. {
58. curl_setopt($ch, CURLOPT_PUT, true);
59. }
60. //curl_setopt($ch, CURLOPT_PROGRESS, true);
61. //curl_setopt($ch, CURLOPT_VERBOSE, true);
62. //curl_setopt($ch, CURLOPT_MUTE, false);
63. curl_setopt($ch, CURLOPT_TIMEOUT, 3);//设置curl超时秒数，例如将信息POST出去3秒钟后自动结束运行。
64. if (strlen($userAgent))
65. {
66. curl_setopt($ch, CURLOPT_USERAGENT, $userAgent);
67. }
68. if (is_array($httpHeaders))
69. {
70. curl_setopt($ch, CURLOPT_HTTPHEADER, $httpHeaders);
71. }
72. $ret = curl_exec($ch);
73. if (curl_errno($ch))
74. {
75. curl_close($ch);
76. returnarray(curl_error($ch), curl_errno($ch));
77. }
78. else
79. {
80. curl_close($ch);
81. if (!is_string($ret) || !strlen($ret))
82. {
83. return false;
84. }
85. return$ret;
86. }
87. }
88. function post($url, $fields, $userAgent = ”, $httpHeaders = ”, $username = ”, $password = ”)
89. {
90. $ret = Curl_Class::execute(‘POST’, $url, $fields, $userAgent, $httpHeaders, $username, $password);
91. if (false === $ret)
92. {
93. return false;
94. }
95. if (is_array($ret))
96. {
97. return false;
98. }
99. return$ret;
100. }
101. function get($url, $userAgent = ”, $httpHeaders = ”, $username = ”, $password = ”)
102. {
103. $ret = Curl_Class::execute(‘GET’, $url, ”, $userAgent, $httpHeaders, $username, $password);
104. if (false === $ret)
105. {
106. return false;
107. }
108. if (is_array($ret))
109. {
110. return false;
111. }
112. return$ret;
113. }
114. function create()
115. {
116. $ch = null;
117. if (!function_exists(‘curl_init’))
118. {
119. return false;
120. }
121. $ch = curl_init();
122. if (!is_resource($ch))
123. {
124. return false;
125. }
126. return$ch;
127. }
128. }
129. ?>

b.php程序源代码：

view plain print ?

2. ignore_user_abort();//连线中断后（例如关闭浏览 器）仍然继续执行以下的脚本直到处理完毕。
3. set_time_limit(0);
4. $get_data = file_get_contents(“php://input”);
5. $explodedata = explode(“&”, $get_data);
6. foreach ($explodedataas$key => $value)//还原数组
7. {
8. list($realkey, $realvalue) = explode(“=”, $value);
9. $data[urldecode($realkey)] = urldecode($realvalue);
10. }
11. //现在$data数组已经和a.php中的一样了，接下来，就可以根据自己的需要对$data数组进行操作了。
12. //……
13. ?>

备注：这两段代码需要php curl扩展库的支持，查看phpinfo()，如果cURL support  enabled则表示支持curl库。 1、Windows下的PHP开启curl库支持： 打开 php.ini，将extension=php_curl.dll前的;号去掉。

2、Linux下的PHP开启curl库支持：

• php