用于向Web服务发出http post请求的多线程

Question

我想在C#中向Web服务发送多个HTTP post请求.例如,如果n = 3,则应该发出来自3个xml文件的http post请求,并且响应应该写在文件中.前3个请求是然后做出接下来的3个请求.所以我做了以下代码,但我首先得到随机输出.但现在我要么在内部for循环或内部服务器错误(500)中超出索引范围异常.Plz建议适当的改变.我使用的是.NET4.0

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.IO;
using System.Threading;
using System.Xml;
using System.Net;
using System.Threading.Tasks;
namespace ConsoleApplication5
{
class Program
{
    static void Main(string[] args)
    {
        int n = 0;
        Console.WriteLine("Enter the number");
        string s = Console.ReadLine();
        int.TryParse(s, out n);
        string path = "C:\\";
        string[] files = null;
        files = Directory.GetFiles(path, "*.xml", SearchOption.TopDirectoryOnly);


        List<Task> tasks = new List<Task>(files.Length);

        for (int i = 0; i < files.Length; i += n)
        {
            for (int j = 0; j < n; j++)
            {
                int x = i + j;

                if (x < files.Length && files[x] != null)
                {
                    Task t = new Task(() => function(files[x]));
                    t.Start();
                    tasks.Add(t);
                }
            }

            if (tasks.Count > 0)
            {
                Task.WaitAll(tasks.ToArray(), Timeout.Infinite); // or less than infinite
                tasks.Clear();
            }
        }
    }
    public static void function(string temp)
    {
        XmlDocument doc = new XmlDocument();
        doc.Load(temp);
        HttpWebRequest request = (HttpWebRequest)WebRequest.Create("http://10.76.22.135/wpaADws/ADService.asmx");

        request.ContentType = "text/xml;charset=\"utf-8\"";
        request.Accept = "text/xml";
        request.Method = "POST";
        Stream stream = request.GetRequestStream();
        doc.Save(stream);
        stream.Close();
        HttpWebResponse response = (HttpWebResponse)request.GetResponse();
        using (StreamReader rd = new StreamReader(response.GetResponseStream()))
        {
            string soapResult = rd.ReadToEnd();
            doc.LoadXml(soapResult);
            File.WriteAllText(temp, doc.DocumentElement.InnerText);

            //XmlTextWriter xml=new XmlTextWriter(
            Console.WriteLine(soapResult);
            Console.ReadKey();
        }

    }

}

}

Answer 1

这段代码有效。解释：

• 首先，用户给出 .xml 文件的源路径和目标路径。

• Directory.getFiles() 帮助我们获取字符串数组中的 .xml 文件。（我们必须传递 .xml 作为参数）。

• 所以现在基本上发生的事情是，对于我们在源代码中获得的每个文件，都会创建一个线程。

• 但是如果用户想一次发送“n”个请求，那么一次会创建n个线程。
• 除非前面的线程执行完毕，否则不会创建下一组线程。
• 这是由 thread.Join() 确保的。

• 向 Web 服务发出请求后，我们通过 getResponse() 获取响应，并将响应写入存储在目标路径中的 .xml 文件中。

   using System;
   using System.Collections.Generic;
   using System.Linq;
   using System.Text;
   using System.IO;
   using System.Threading;
   using System.Xml;
   using System.Net;
   namespace ConsoleApplication4
   {
       class Program
       {
        int flag = 1;
        string destination;
        string source;
        static void Main(string[] args)
      {
      Console.ForegroundColor = ConsoleColor.Red;
  
      Console.WriteLine("**************************** Send HTTP Post Requests **************************");
      int n = 0;
      Program p = new Program();
      Console.WriteLine("Enter the number of requests you want to send at a time");
      string s = Console.ReadLine();
      int.TryParse(s, out n);
      Console.WriteLine("Enter Source");
      p.source = Console.ReadLine();
      Console.WriteLine("Enter Destination");
      p.destination = Console.ReadLine();
  
      string[] files = null;
      files = Directory.GetFiles(p.source, "*.xml", SearchOption.TopDirectoryOnly);
  
      Thread[] thread = new Thread[files.Length];
  
      int len = files.Length;
      for (int i = 0; i<len; i+=n)
      {
          int x = i;
          //Thread.Sleep(5000);
          for (int j = 0; j < n && x < len; j++)
          {
  
              var localx = x;
              thread[x] = new Thread(() => function(files[localx], p));
              thread[x].Start();
              Thread.Sleep(50);
              //thread[x].Join();
              x++;
          }
          int y = x - n;
          for (; y < x; y++)
          {
              int t = y;
              thread[t].Join();
  
          }
  
      }
  
      // thread[0] = new Thread(() => function(files[0]));
      //thread[0].Start();
      Console.ReadKey();
  
  }
  public static void function(string temp,Program p)
  {
  
      XmlDocument doc = new XmlDocument();
      doc.Load(temp);
  
      string final_d=p.destination + "response " + p.flag + ".xml";
      p.flag++;
      HttpWebRequest request = (HttpWebRequest)WebRequest.Create("http://10.76.22.135/wpaADws/ADService.asmx");
      request.ContentType = "text/xml;charset=\"utf-8\"";
      request.Accept = "text/xml";
      request.Method = "POST";
      Stream stream = request.GetRequestStream();
      doc.Save(stream);
      stream.Close();
  
      HttpWebResponse response = (HttpWebResponse)request.GetResponse();
      using (StreamReader rd = new StreamReader(response.GetResponseStream()))
      {
          string soapResult = rd.ReadToEnd();
          doc.LoadXml(soapResult);
          File.WriteAllText(final_d, doc.DocumentElement.InnerText);
  
          //XmlTextWriter xml=new XmlTextWriter(
          Console.WriteLine(soapResult);
          //Console.ReadKey();
      }
  }
  

  } }