boost asio 壓力測試六小時後 Killed 的原因?

fiendcly

hellioncu 发表于 2012-08-24 09:02
这么晚还干活

是啊~在趕工......

快做完了.

現在不停的測穩定性 ^^

cdtits

测试代码呢？

fiendcly

cdtits 发表于 2012-08-26 00:37
测试代码呢？

我中間有將它跟 php-fpm 接起來 使用 fastcgi.h 跟 PHP-FPM 接起來.

CLIENT 端 直接寫支~SOCKET 程式 不停的 FORK 新的 PROCESS ~

在連線後 ,  丟 一億個 WRITE OR SEND 進去.

1. /*
   
2. * fastcgi.h --
   
3. *
   
4. *        Defines for the FastCGI protocol.
   
5. *
   
6. *
   
7. * Copyright (c) 1995-1996 Open Market, Inc.
   
8. *
   
9. * See the file "LICENSE.TERMS" for information on usage and redistribution
   
10. * of this file, and for a DISCLAIMER OF ALL WARRANTIES.
    
11. *
    
12. * $Id: fastcgi.h,v 1.1.1.1 1997/09/16 15:36:32 stanleyg Exp $
    
13. */
    
14. 
    
15. #ifndef _FASTCGI_H
    
16. #define _FASTCGI_H
    
17. 
    
18. /*
    
19. * Listening socket file number
    
20. */
    
21. #define FCGI_LISTENSOCK_FILENO 0
    
22. 
    
23. typedef struct {
    
24.     unsigned char version;
    
25.     unsigned char type;
    
26.     unsigned char requestIdB1;
    
27.     unsigned char requestIdB0;
    
28.     unsigned char contentLengthB1;
    
29.     unsigned char contentLengthB0;
    
30.     unsigned char paddingLength;
    
31.     unsigned char reserved;
    
32. } FCGI_Header;
    
33. 
    
34. #define FCGI_MAX_LENGTH 0xffff
    
35. 
    
36. /*
    
37. * Number of bytes in a FCGI_Header.  Future versions of the protocol
    
38. * will not reduce this number.
    
39. */
    
40. #define FCGI_HEADER_LEN  8
    
41. 
    
42. /*
    
43. * Value for version component of FCGI_Header
    
44. */
    
45. #define FCGI_VERSION_1           1
    
46. 
    
47. /*
    
48. * Values for type component of FCGI_Header
    
49. */
    
50. #define FCGI_BEGIN_REQUEST       1
    
51. #define FCGI_ABORT_REQUEST       2
    
52. #define FCGI_END_REQUEST         3
    
53. #define FCGI_PARAMS              4
    
54. #define FCGI_STDIN               5
    
55. #define FCGI_STDOUT              6
    
56. #define FCGI_STDERR              7
    
57. #define FCGI_DATA                8
    
58. #define FCGI_GET_VALUES          9
    
59. #define FCGI_GET_VALUES_RESULT  10
    
60. #define FCGI_UNKNOWN_TYPE       11
    
61. #define FCGI_MAXTYPE (FCGI_UNKNOWN_TYPE)
    
62. 
    
63. /*
    
64. * Value for requestId component of FCGI_Header
    
65. */
    
66. #define FCGI_NULL_REQUEST_ID     0
    
67. 
    
68. 
    
69. typedef struct {
    
70.     unsigned char roleB1;
    
71.     unsigned char roleB0;
    
72.     unsigned char flags;
    
73.     unsigned char reserved[5];
    
74. } FCGI_BeginRequestBody;
    
75. 
    
76. typedef struct {
    
77.     FCGI_Header header;
    
78.     FCGI_BeginRequestBody body;
    
79. } FCGI_BeginRequestRecord;
    
80. 
    
81. /*
    
82. * Mask for flags component of FCGI_BeginRequestBody
    
83. */
    
84. #define FCGI_KEEP_CONN  1
    
85. 
    
86. /*
    
87. * Values for role component of FCGI_BeginRequestBody
    
88. */
    
89. #define FCGI_RESPONDER  1
    
90. #define FCGI_AUTHORIZER 2
    
91. #define FCGI_FILTER     3
    
92. 
    
93. 
    
94. typedef struct {
    
95.     unsigned char appStatusB3;
    
96.     unsigned char appStatusB2;
    
97.     unsigned char appStatusB1;
    
98.     unsigned char appStatusB0;
    
99.     unsigned char protocolStatus;
    
100.     unsigned char reserved[3];
     
101. } FCGI_EndRequestBody;
     
102. 
     
103. typedef struct {
     
104.     FCGI_Header header;
     
105.     FCGI_EndRequestBody body;
     
106. } FCGI_EndRequestRecord;
     
107. 
     
108. /*
     
109. * Values for protocolStatus component of FCGI_EndRequestBody
     
110. */
     
111. #define FCGI_REQUEST_COMPLETE 0
     
112. #define FCGI_CANT_MPX_CONN    1
     
113. #define FCGI_OVERLOADED       2
     
114. #define FCGI_UNKNOWN_ROLE     3
     
115. 
     
116. 
     
117. /*
     
118. * Variable names for FCGI_GET_VALUES / FCGI_GET_VALUES_RESULT records
     
119. */
     
120. #define FCGI_MAX_CONNS  "FCGI_MAX_CONNS"
     
121. #define FCGI_MAX_REQS   "FCGI_MAX_REQS"
     
122. #define FCGI_MPXS_CONNS "FCGI_MPXS_CONNS"
     
123. 
     
124. 
     
125. typedef struct {
     
126.     unsigned char type;   
     
127.     unsigned char reserved[7];
     
128. } FCGI_UnknownTypeBody;
     
129. 
     
130. typedef struct {
     
131.     FCGI_Header header;
     
132.     FCGI_UnknownTypeBody body;
     
133. } FCGI_UnknownTypeRecord;
     
134. 
     
135. #endif        /* _FASTCGI_H */
     

复制代码

http://www.boost.org/
BOOST 裡有 範例程式.
http://www.boost.org/doc/libs/1_ ... _asio/examples.html

用 異步 IO 的 ECHO SERVER.

1. //
   
2. // async_tcp_echo_server.cpp
   
3. // ~~~~~~~~~~~~~~~~~~~~~~~~~
   
4. //
   
5. // Copyright (c) 2003-2012 Christopher M. Kohlhoff (chris at kohlhoff dot com)
   
6. //
   
7. // Distributed under the Boost Software License, Version 1.0. (See accompanying
   
8. // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
   
9. //
   
10. 
    
11. #include <cstdlib>
    
12. #include <iostream>
    
13. #include <boost/bind.hpp>
    
14. #include <boost/asio.hpp>
    
15. 
    
16. using boost::asio::ip::tcp;
    
17. 
    
18. class session
    
19. {
    
20. public:
    
21.   session(boost::asio::io_service& io_service)
    
22.     : socket_(io_service)
    
23.   {
    
24.   }
    
25. 
    
26.   tcp::socket& socket()
    
27.   {
    
28.     return socket_;
    
29.   }
    
30. 
    
31.   void start()
    
32.   {
    
33.     socket_.async_read_some(boost::asio::buffer(data_, max_length),
    
34.         boost::bind(&session::handle_read, this,
    
35.           boost::asio::placeholders::error,
    
36.           boost::asio::placeholders::bytes_transferred));
    
37.   }
    
38. 
    
39. private:
    
40.   void handle_read(const boost::system::error_code& error,
    
41.       size_t bytes_transferred)
    
42.   {
    
43.     if (!error)
    
44.     {
    
45.       boost::asio::async_write(socket_,
    
46.           boost::asio::buffer(data_, bytes_transferred),
    
47.           boost::bind(&session::handle_write, this,
    
48.             boost::asio::placeholders::error));
    
49.     }
    
50.     else
    
51.     {
    
52.       delete this;
    
53.     }
    
54.   }
    
55. 
    
56.   void handle_write(const boost::system::error_code& error)
    
57.   {
    
58.     if (!error)
    
59.     {
    
60.       socket_.async_read_some(boost::asio::buffer(data_, max_length),
    
61.           boost::bind(&session::handle_read, this,
    
62.             boost::asio::placeholders::error,
    
63.             boost::asio::placeholders::bytes_transferred));
    
64.     }
    
65.     else
    
66.     {
    
67.       delete this;
    
68.     }
    
69.   }
    
70. 
    
71.   tcp::socket socket_;
    
72.   enum { max_length = 1024 };
    
73.   char data_[max_length];
    
74. };
    
75. 
    
76. class server
    
77. {
    
78. public:
    
79.   server(boost::asio::io_service& io_service, short port)
    
80.     : io_service_(io_service),
    
81.       acceptor_(io_service, tcp::endpoint(tcp::v4(), port))
    
82.   {
    
83.     start_accept();
    
84.   }
    
85. 
    
86. private:
    
87.   void start_accept()
    
88.   {
    
89.     session* new_session = new session(io_service_);
    
90.     acceptor_.async_accept(new_session->socket(),
    
91.         boost::bind(&server::handle_accept, this, new_session,
    
92.           boost::asio::placeholders::error));
    
93.   }
    
94. 
    
95.   void handle_accept(session* new_session,
    
96.       const boost::system::error_code& error)
    
97.   {
    
98.     if (!error)
    
99.     {
    
100.       new_session->start();
     
101.     }
     
102.     else
     
103.     {
     
104.       delete new_session;
     
105.     }
     
106. 
     
107.     start_accept();
     
108.   }
     
109. 
     
110.   boost::asio::io_service& io_service_;
     
111.   tcp::acceptor acceptor_;
     
112. };
     
113. 
     
114. int main(int argc, char* argv[])
     
115. {
     
116.   try
     
117.   {
     
118.     if (argc != 2)
     
119.     {
     
120.       std::cerr << "Usage: async_tcp_echo_server <port>\n";
     
121.       return 1;
     
122.     }
     
123. 
     
124.     boost::asio::io_service io_service;
     
125. 
     
126.     using namespace std; // For atoi.
     
127.     server s(io_service, atoi(argv[1]));
     
128. 
     
129.     io_service.run();
     
130.   }
     
131.   catch (std::exception& e)
     
132.   {
     
133.     std::cerr << "Exception: " << e.what() << "\n";
     
134.   }
     
135. 
     
136.   return 0;
     
137. }

复制代码