【调查帖】你对<鱼刺多线程模块>和多线程方面有疑问吗

zengzhijiang

谢谢分享123

Dhs过客

有一种爱叫无私奉献！

火威网络

有一种爱叫无私奉献！

wmdgd

好多问题想问,好想看教程例子

lindseygan

好多问题想问,好想看教程例子

lindseygan

好多问题想问,好想看教程例子

a385937922

鱼刺例子有公布吗？

gulibo2001

手里有C#的HttpWebRequest里面ssl提到了x509证书协yi用鱼刺应该怎么写呢？

1. public class HttpService
   
2.     {
   
3. 
   
4.         public static bool CheckValidationResult(object sender, X509Certificate certificate, X509Chain chain, SslPolicyErrors errors)
   
5.         {
   
6.             //直接确认，否则打不开   
   
7.             return true;
   
8.         }
   
9. 
   
10.         public static string Post(string xml, string url, bool isUseCert, int timeout)
    
11.         {
    
12.             System.GC.Collect();//垃圾回收，回收没有正常关闭的http连接
    
13. 
    
14.             string result = "";//返回结果
    
15. 
    
16.             HttpWebRequest request = null;
    
17.             HttpWebResponse response = null;
    
18.             Stream reqStream = null;
    
19. 
    
20.             try
    
21.             {
    
22.                 //设置最大连接数
    
23.                 ServicePointManager.DefaultConnectionLimit = 200;
    
24.                 //设置https验证方式
    
25.                 if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
    
26.                 {
    
27.                     ServicePointManager.ServerCertificateValidationCallback =
    
28.                             new RemoteCertificateValidationCallback(CheckValidationResult);
    
29.                 }
    
30. 
    
31.                 /***************************************************************
    
32.                 * 下面设置HttpWebRequest的相关属性
    
33.                 * ************************************************************/
    
34.                 request = (HttpWebRequest)WebRequest.Create(url);
    
35. 
    
36.                 request.Method = "POST";
    
37.                 request.Timeout = timeout * 1000;
    
38. 
    
39.                 //设置代理服务器
    
40.                 //WebProxy proxy = new WebProxy();                          //定义一个网关对象
    
41.                 //proxy.Address = new Uri(WxPayConfig.PROXY_URL);              //网关服务器端口:端口
    
42.                 //request.Proxy = proxy;
    
43. 
    
44.                 //设置POST的数据类型和长度
    
45.                 request.ContentType = "text/xml";
    
46.                
    
47.                 byte[] data = System.Text.Encoding.UTF8.GetBytes(xml);
    
48.                 request.ContentLength = data.Length;
    
49.                 Console.WriteLine(request.Headers);
    
50.                 //是否使用证书
    
51.                 if (isUseCert)
    
52.                 {
    
53.                 //    string path = HttpContext.Current.Request.PhysicalApplicationPath;
    
54.                 //    X509Certificate2 cert = new X509Certificate2(path + Config.SSLCERT_PATH, Config.SSLCERT_PASSWORD);
    
55.                 //    request.ClientCertificates.Add(cert);
    
56.                 ////    Log.Debug("WxPayApi", "PostXml used cert");
    
57.                 }
    
58. 
    
59.                 //往服务器写入数据
    
60.                 reqStream = request.GetRequestStream();
    
61.                 reqStream.Write(data, 0, data.Length);
    
62.                 reqStream.Close();
    
63.                
    
64.                 //获取服务端返回
    
65.                 response = (HttpWebResponse)request.GetResponse();
    
66. 
    
67.                 //获取服务端返回数据
    
68.                 StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
    
69.                
    
70.                 result = sr.ReadToEnd().Trim();
    
71.                 sr.Close();
    
72.             }
    
73.             //catch (System.Threading.ThreadAbortException e)
    
74.             //{
    
75.             //   // Log.Error("HttpService", "Thread - caught ThreadAbortException - resetting.");
    
76.             //   // Log.Error("Exception message: {0}", e.Message);
    
77.             //    System.Threading.Thread.ResetAbort();
    
78.             //}
    
79.             //catch (WebException e)
    
80.             //{
    
81.             // //   Log.Error("HttpService", e.ToString());
    
82.             //    if (e.Status == WebExceptionStatus.ProtocolError)
    
83.             //    {
    
84.             //    //    Log.Error("HttpService", "StatusCode : " + ((HttpWebResponse)e.Response).StatusCode);
    
85.             //     //   Log.Error("HttpService", "StatusDescription : " + ((HttpWebResponse)e.Response).StatusDescription);
    
86.             //    }
    
87.             //    throw new WxPayException(e.ToString());
    
88.             //}
    
89.             //catch (Exception e)
    
90.             //{
    
91.             //   // Log.Error("HttpService", e.ToString());
    
92.             //    throw new WxPayException(e.ToString());
    
93.             //}
    
94.             finally
    
95.             {
    
96.                 //关闭连接和流
    
97.                 if (response != null)
    
98.                 {
    
99.                     response.Close();
    
100.                 }
     
101.                 if (request != null)
     
102.                 {
     
103.                     request.Abort();
     
104.                 }
     
105.             }
     
106.             return result;
     
107.         }
     
108. 
     
109.         /// <summary>
     
110.         /// 处理http GET请求，返回数据
     
111.         /// </summary>
     
112.         /// <param name="url">请求的url地址</param>
     
113.         /// <returns>http GET成功后返回的数据，失败抛WebException异常</returns>
     
114.         public static string Get(string url)
     
115.         {
     
116.             System.GC.Collect();
     
117.             string result = "";
     
118. 
     
119.             HttpWebRequest request = null;
     
120.             HttpWebResponse response = null;
     
121. 
     
122.             //请求url以获取数据
     
123.             try
     
124.             {
     
125.                 //设置最大连接数
     
126.                 ServicePointManager.DefaultConnectionLimit = 200;
     
127.                 //设置https验证方式
     
128.                 if (url.StartsWith("https", StringComparison.OrdinalIgnoreCase))
     
129.                 {
     
130.                     ServicePointManager.ServerCertificateValidationCallback =
     
131.                             new RemoteCertificateValidationCallback(CheckValidationResult);
     
132.                 }
     
133. 
     
134.                 /***************************************************************
     
135.                 * 下面设置HttpWebRequest的相关属性
     
136.                 * ************************************************************/
     
137.                 request = (HttpWebRequest)WebRequest.Create(url);
     
138. 
     
139.                 request.Method = "GET";
     
140. 
     
141.                 //设置代理
     
142.                 //WebProxy proxy = new WebProxy();
     
143.                 //proxy.Address = new Uri(WxPayConfig.PROXY_URL);
     
144.                 //request.Proxy = proxy;
     
145. 
     
146.                 //获取服务器返回
     
147.                 response = (HttpWebResponse)request.GetResponse();
     
148. 
     
149.                 //获取HTTP返回数据
     
150.                 StreamReader sr = new StreamReader(response.GetResponseStream(), Encoding.UTF8);
     
151.                 result = sr.ReadToEnd().Trim();
     
152.                 sr.Close();
     
153.             }
     
154.             //catch (System.Threading.ThreadAbortException e)
     
155.             //{
     
156.             //  //  Log.Error("HttpService", "Thread - caught ThreadAbortException - resetting.");
     
157.             //   // Log.Error("Exception message: {0}", e.Message);
     
158.             //    System.Threading.Thread.ResetAbort();
     
159.             //}
     
160.             //catch (WebException e)
     
161.             //{
     
162.             // //   Log.Error("HttpService", e.ToString());
     
163.             //    if (e.Status == WebExceptionStatus.ProtocolError)
     
164.             //    {
     
165.             //     //   Log.Error("HttpService", "StatusCode : " + ((HttpWebResponse)e.Response).StatusCode);
     
166.             //     //   Log.Error("HttpService", "StatusDescription : " + ((HttpWebResponse)e.Response).StatusDescription);
     
167.             //    }
     
168.             //    throw new Exception(e.ToString());
     
169.             //}
     
170.             //catch (Exception e)
     
171.             //{
     
172.             // //   Log.Error("HttpService", e.ToString());
     
173.             //    throw new Exception(e.ToString());
     
174.             //}
     
175.             finally
     
176.             {
     
177.                 //关闭连接和流
     
178.                 if (response != null)
     
179.                 {
     
180.                     response.Close();
     
181.                 }
     
182.                 if (request != null)
     
183.                 {
     
184.                     request.Abort();
     
185.                 }
     
186.             }
     
187.             return result;
     
188.         }
     
189.     }

复制代码

eternity987987

期待教程，看到原子锁什么晕了

哒00哒

什么时候出教程啊！！