webService并发处理 web_service_wait_for_event

dominge

最近做webservice性能测试，系统是用C#开发，支持后台线程，通过事件委托实现了webservice调用的异步处理。

性能测试需求，在一个Vuser中，将调用webservice的web_service_call函数和处理web Service返回结果分开，能够让多个webservice调用并发进行。而不是串行的。

我的现在的代码如下，能够进一步优化吗？  此代码解决了webservice返回值为xml文件的问题，有需要的可以看一下。

1. action()
   
2. {
   
3. 
   
4. 
   
5.         int Num ,i;
   
6.         char po[64],pt[64],vt[64],ptime[64];
   
7. 
   
8. 
   
9.         typedef long time_t;
   
10.     time_t t;
    
11.         lr_message ("Time in seconds since 1/1/70: %ld\n", time(&t));
    
12. 
    
13.         lr_save_int((time(&t)-604800),"begintime");
    
14.         lr_save_int(time(&t),"endtime");
    
15. 
    
16.         web_service_call( "StepName=getFisheriesSchema_101",
    
17.                 "SOAPMethod=DataService|DataServiceSoap|getFisheriesSchema",
    
18.                 "ResponseParam=response",
    
19.                 "Service=DataService",
    
20.                 "ExpectedResponse=SoapResult",
    
21.                 "Snapshot=t1377561681.inf",
    
22.                 BEGIN_ARGUMENTS,
    
23.                 "userName=IDP",
    
24.                 "password=IDP",
    
25.                 "reqSn=1",
    
26.                 "beginTime={begintime}",
    
27.                 "endTime={endtime}",
    
28.                 END_ARGUMENTS,
    
29.                 BEGIN_RESULT,
    
30.                 "getFisheriesSchemaResult=Param_getFisheriesSchemaResult",
    
31.                 END_RESULT,
    
32.                 LAST);
    
33. 
    
34.                 lr_output_message(lr_eval_string("{Param_getFisheriesSchemaResult}"));
    
35. 
    
36.                 lr_convert_string_encoding(lr_eval_string("{Param_getFisheriesSchemaResult}"),LR_ENC_SYSTEM_LOCALE,LR_ENC_UTF8,"str");
    
37. 
    
38.                 Num = lr_xml_get_values("XML={str}",
    
39.                                                 "valueParam=ProdOrg",
    
40.                                                 "Query=/getFisheriesSchemaResult/ProductSchema/ProdOrg",
    
41.                                                 "SelectAll=yes",
    
42.                                                 LAST);
    
43.                 lr_xml_get_values("XML={str}",
    
44.                                                 "valueParam=PostTime",
    
45.                                                 "Query=/getFisheriesSchemaResult/ProductSchema/Post_Time",
    
46.                                                 "SelectAll=yes",
    
47.                                                 LAST);
    
48. 
    
49.                 lr_xml_get_values("XML={str}",
    
50.                                                 "valueParam=VType",
    
51.                                                 "Query=/getFisheriesSchemaResult/ProductSchema/VType",
    
52.                                                 "SelectAll=yes",
    
53.                                                 LAST);
    
54.                 lr_xml_get_values("XML={str}",
    
55.                                                 "valueParam=ProdType",
    
56.                                                 "Query=/getFisheriesSchemaResult/ProductSchema/ProdType",
    
57.                                                 "SelectAll=yes",
    
58.                                                 LAST);
    
59. 
    
60.                 for ( i = 0; i < Num; i++) { /* Print multiple values of OutputParam */
    
61.            sprintf (po, "{ProdOrg_%d}", i+1, i+1);
    
62.                    sprintf (ptime,"{PostTime_%d}", i+1, i+1);
    
63.                    sprintf (vt, "{VType_%d}", i+1, i+1);
    
64.                    sprintf (pt, "{ProdType_%d}", i+1, i+1);
    
65. 
    
66.                    lr_save_var(lr_eval_string(pt),1,0,"temp1");
    
67.                    lr_save_var(lr_eval_string(po),8,0,"temp2");
    
68.                    lr_save_var(lr_eval_string(ptime),17,0,"temp3");
    
69.                    lr_save_var(lr_eval_string(vt),1,0,"temp4");
    
70.                   
    
71. 
    
72.         web_service_call( "StepName=getFisheries_101",
    
73.                 "SOAPMethod=DataService|DataServiceSoap|getFisheries",
    
74.                 "ResponseParam=response",
    
75.                 "Service=DataService",
    
76.                 "ExpectedResponse=SoapResult",
    
77.                 "Snapshot=t1377562576.inf",
    
78.                 BEGIN_ARGUMENTS,
    
79.                 "userName=IDP",
    
80.                 "password=IDP",
    
81.                 "reqSn=1",
    
82.                 "xml:ps="
    
83.                         "<ps>"
    
84.                                 "<ProdType>{temp1}</ProdType>"
    
85.                                 "<ProdOrg>{temp2}</ProdOrg>"
    
86.                                 "<Post_Time>{temp3}</Post_Time>"
    
87.                                 "<VType>{temp4}</VType>"
    
88.                         "</ps>",
    
89.                 END_ARGUMENTS,
    
90.                 BEGIN_RESULT,
    
91.                 "getFisheriesResult/Result=Param_Result",
    
92.                 "getFisheriesResult/Resource=Param_Resource",
    
93.                 END_RESULT,
    
94.                 LAST);
    
95. 
    
96.                 lr_output_message(lr_eval_string("{Param_Resource}"));
    
97. 
    
98. 
    
99.        
    
100.        
     
101.                 lr_save_var(lr_eval_string("{Param_Resource}")+24,29,0,"result");
     
102. 
     
103.                 FtpLoading(lr_eval_string("{result}"));
     
104. 
     
105.                 }
     
106. 
     
107.                 return TRUE;
     
108. }

复制代码

在LoadRunner函数库中看到了这么一个函数 web_service_wait_for_event。实例如下：

1. web_service_call( "StepName=EchoString_101",
   
2. 
   
3.     "SOAPMethod=
   
4. 
   
5. ExtendedECHO_rpc_encoded|ExtendedECHO_rpc_encodedSoap|EchoString",
   
6. 
   
7.     "ResponseParam=response",
   
8. 
   
9.     "Service=ExtendedECHO_rpc_encoded",
   
10. 
    
11.     "AsyncEvent=first_event",
    
12. 
    
13.     BEGIN_ARGUMENTS,
    
14. 
    
15.     "sec=7",
    
16. 
    
17.     "strString=jabberwocky",
    
18. 
    
19.     END_ARGUMENTS,
    
20. 
    
21.     BEGIN_RESULT,
    
22. 
    
23.     "EchoStringResult=first_call",
    
24. 
    
25.     END_RESULT,
    
26. 
    
27.     LAST );
    
28. 
    
29. web_service_call( "StepName=EchoString_102",
    
30. 
    
31.     "SOAPMethod=
    
32. 
    
33. ExtendedECHO_rpc_encoded|ExtendedECHO_rpc_encodedSoap|EchoString",
    
34. 
    
35.     "ResponseParam=response",
    
36. 
    
37.     "Service=ExtendedECHO_rpc_encoded",
    
38. 
    
39.     "AsyncEvent=second_event",
    
40. 
    
41.     BEGIN_ARGUMENTS,
    
42. 
    
43.     "sec=2",
    
44. 
    
45.     "strString=borogoves",
    
46. 
    
47.     END_ARGUMENTS,
    
48. 
    
49.     BEGIN_RESULT,
    
50. 
    
51.     "EchoStringResult=second_call",
    
52. 
    
53.     END_RESULT,
    
54. 
    
55.     LAST );
    
56. 
    
57. lr_output_message("got event %s",
    
58. 
    
59.     web_service_wait_for_event("StepName=WaitHere",
    
60. 
    
61.         "Quantifier=ALL",
    
62. 
    
63.         "Timeout=10000",
    
64. 
    
65.         BEGIN_EVENTS,
    
66. 
    
67.         "first_event",
    
68. 
    
69.         "second_event",
    
70. 
    
71.         END_EVENTS,
    
72. 
    
73.         LAST)
    
74. 
    
75.     );
    
76. 
    

复制代码

求助大神讲讲这个函数能够实现我的需求吗？