多线程模拟客户端并发
2012-01-11 11:40
399 查看
多线程模拟客户端并发
还是webservice项目的测试:
模拟尽可能多的并发来测试webservice性能,我采用了多线程的方式来进行模拟,首先介绍一下思路:需要模拟每秒1000个并发数据,那么大略的计算方法:设置能够处理的最大线程数1000,超过1000的时候让它挂起1ms,资料有个粗略的计算(处理过程时间忽略不计,理想状态)
1
public class ThreadTest
2
{
3
private int poolFlag = 0;//标记
4
private const int amountThread = 2000;//线程总量
5
private int maxThread = 1000;//可执行线程最大数量
6
private Mutex muxConsole = new Mutex();
7
8
public void TestStart(int iThread)
9
{
10
if (iThread > 0)
11
{
12
maxThread = iThread;
13
}
14
for (int i = 0; i < amountThread; i++)
15
{
16
// 创建指定数量的线程
17
// 是线程调用Run方法
18
// 启动线程
19
Thread trd = new Thread(new ThreadStart(Run));
20
21
trd.Start();
22
}
23
}
24
25
public void Run()
26
{
27
muxConsole.WaitOne(); //阻塞队列
28
Interlocked.Increment(ref poolFlag); //标记+1
29
if (poolFlag != maxThread) //判断是否等于上限
30
{
31
GetService(); //处理方法,请求webservice
32
33
muxConsole.ReleaseMutex(); //如果此线程达不到可执行线程上限,则继续开通,让后面的线程进来
34
}
35
else
36
{
37
Thread.Sleep(1000/maxThread); //模拟执行,Sleep的时间,理想状态计算可控制每秒模拟的请求数
38
}
39
40
//标记-1
41
Interlocked.Decrement(ref poolFlag);
42
} }
以下引用别人的经验之谈:
C#提供了Mutex与Interlocked这两个与线程相关的类,都在Threading命名空间下~!
Mutex中提供了WiteOne,ReleaseMutex 两个实例方法~
WiteOne的作用是"阻塞当前线程,提供对该线程的原子操作"
也就是说当一个线程遇到WiteOne的时候,如果在WiteOne里面没有线程在操作,则此线程进去操作
而里面有线程的时候,所有到此的线程均需要排队等候里面的线程执行完毕~
而控制这样操作的结束标记就是使用ReleaseMutex 方法!
就好比WiteOne是一把锁一样~而ReleaseMutex 就是一把钥匙
当10个人都看到这个门的时候,第一个到达门口的人会看到屋子里没有人,则他进去,同时会把门锁上~
后面的人自然要在门口等候,当此人在屋子里执行完任务后他会用钥匙把门打开!
出去后把锁交给门口排队的第二位同志,第二位同志再做同样的操作
如果第一位同志执行完任务以后不把使用权交给第二个人的话,而直接退出
那么屋子自然就空了下来,而门还是锁的~不必担心~门会自动打开,只要是前一个人已经不在屋子里即可~
然后再来说说这个Interlocked,官方说明是"对一个变量进行原子操作进行递增或者递减然后保存"
原子操作的概念就是,有且只有一个线程在对此变量进行操作~不准其他线程干预的操作
当对一个变量进行原子操作的时候,此变量就会加锁,而其他线程是无法访问的,只能挂起等候此变量解锁
本人总结:
GetService()方法中是通过new 来请求web服务的,这样的话只能实现并发"请求"多次web服务,而不能模拟出并发多次"连接"并"请求"的功能.
找到关于创建HTTP连接的方式:
WebRequest myRequest = WebRequest.Create("http://mywebservicedomain");
GetService();
WebResponse myRespone = myRequest.GetResponse();
myRespone.Close();
还是webservice项目的测试:
模拟尽可能多的并发来测试webservice性能,我采用了多线程的方式来进行模拟,首先介绍一下思路:需要模拟每秒1000个并发数据,那么大略的计算方法:设置能够处理的最大线程数1000,超过1000的时候让它挂起1ms,资料有个粗略的计算(处理过程时间忽略不计,理想状态)
1
public class ThreadTest
2
{
3
private int poolFlag = 0;//标记
4
private const int amountThread = 2000;//线程总量
5
private int maxThread = 1000;//可执行线程最大数量
6
private Mutex muxConsole = new Mutex();
7
8
public void TestStart(int iThread)
9
{
10
if (iThread > 0)
11
{
12
maxThread = iThread;
13
}
14
for (int i = 0; i < amountThread; i++)
15
{
16
// 创建指定数量的线程
17
// 是线程调用Run方法
18
// 启动线程
19
Thread trd = new Thread(new ThreadStart(Run));
20
21
trd.Start();
22
}
23
}
24
25
public void Run()
26
{
27
muxConsole.WaitOne(); //阻塞队列
28
Interlocked.Increment(ref poolFlag); //标记+1
29
if (poolFlag != maxThread) //判断是否等于上限
30
{
31
GetService(); //处理方法,请求webservice
32
33
muxConsole.ReleaseMutex(); //如果此线程达不到可执行线程上限,则继续开通,让后面的线程进来
34
}
35
else
36
{
37
Thread.Sleep(1000/maxThread); //模拟执行,Sleep的时间,理想状态计算可控制每秒模拟的请求数
38
}
39
40
//标记-1
41
Interlocked.Decrement(ref poolFlag);
42
} }
以下引用别人的经验之谈:
C#提供了Mutex与Interlocked这两个与线程相关的类,都在Threading命名空间下~!
Mutex中提供了WiteOne,ReleaseMutex 两个实例方法~
WiteOne的作用是"阻塞当前线程,提供对该线程的原子操作"
也就是说当一个线程遇到WiteOne的时候,如果在WiteOne里面没有线程在操作,则此线程进去操作
而里面有线程的时候,所有到此的线程均需要排队等候里面的线程执行完毕~
而控制这样操作的结束标记就是使用ReleaseMutex 方法!
就好比WiteOne是一把锁一样~而ReleaseMutex 就是一把钥匙
当10个人都看到这个门的时候,第一个到达门口的人会看到屋子里没有人,则他进去,同时会把门锁上~
后面的人自然要在门口等候,当此人在屋子里执行完任务后他会用钥匙把门打开!
出去后把锁交给门口排队的第二位同志,第二位同志再做同样的操作
如果第一位同志执行完任务以后不把使用权交给第二个人的话,而直接退出
那么屋子自然就空了下来,而门还是锁的~不必担心~门会自动打开,只要是前一个人已经不在屋子里即可~
然后再来说说这个Interlocked,官方说明是"对一个变量进行原子操作进行递增或者递减然后保存"
原子操作的概念就是,有且只有一个线程在对此变量进行操作~不准其他线程干预的操作
当对一个变量进行原子操作的时候,此变量就会加锁,而其他线程是无法访问的,只能挂起等候此变量解锁
本人总结:
GetService()方法中是通过new 来请求web服务的,这样的话只能实现并发"请求"多次web服务,而不能模拟出并发多次"连接"并"请求"的功能.
找到关于创建HTTP连接的方式:
WebRequest myRequest = WebRequest.Create("http://mywebservicedomain");
GetService();
WebResponse myRespone = myRequest.GetResponse();
myRespone.Close();
相关文章推荐
- 多线程模拟客户端并发
- Linux下模拟多线程的并发并发shell脚本
- C# winform 窗体接收命令行参数自动登录进行系统,模拟600个WCF客户端的并发压力测试
- 多线程并发服务器与客户端 ---20100514
- TCP--通过多线程实现客户端并发上传图片
- 单例模式之模拟多线程高并发
- Linux下模拟多线程的并发并发shell脚本
- 利用curl 多线程 模拟 并发的详解
- 在使用HttpClient做客户端调用一个API时 模拟并发调用时发生“死锁"?
- 实现多线程并发访问上传客户端及代码实现
- 利用curl 多线程 模拟 并发的详解
- 利用 curl 多线程 模拟 并发
- 利用多线程编写多个客户端向服务器并发数据
- C# winform 窗体接收命令行参数自动登录进行系统,模拟600个WCF客户端的并发压力测试
- python模拟mysql多客户端并发操作
- 黑马程序员 Java练习-模拟TCP客户端并发上传图片
- 流式(TCP)套接字客户端/服务器编程 (多线程并发服务器)
- 查询信息的服务器 客户端设立 支持并发多线程
- 利用curl 多线程 模拟 并发的详解
- 基于tcp协议模拟多客户端并发的图片上传