import org.mortbay.jetty.client.HttpClient; //导入依赖的package包/类
public Worker(CyclicBarrier barrier, int requestsCount, String sessionCookie, String[] urls)
{
    this.client = new HttpClient();
    this.client.setConnectorType(HttpClient.CONNECTOR_SOCKET);
    this.barrier = barrier;
    this.requestsCount = requestsCount;
    this.sessionCookie = sessionCookie;
    this.urls = urls;
}
 

import org.mortbay.jetty.client.HttpClient; //导入依赖的package包/类
public BayeuxClient(HttpClient client, Address address, String uri) throws IOException
{
    _client=client;
    _address=address;
    _uri=uri;

    _inQ=new ArrayQueue<Message>();
    _outQ=new ArrayQueue<Message>();
}
 

import org.mortbay.jetty.client.HttpClient; //导入依赖的package包/类
public BayeuxLoadGenerator() throws Exception
{
    http=new HttpClient();

    http.setConnectorType(HttpClient.CONNECTOR_SELECT_CHANNEL);
    // http.setConnectorType(HttpClient.CONNECTOR_SOCKET);
    http.setMaxConnectionsPerAddress(20000);

    QueuedThreadPool pool = new QueuedThreadPool();
    pool.setMaxThreads(500);
    pool.setDaemon(true);
    http.setThreadPool(pool);
    http.start();

}
 

import org.mortbay.jetty.client.HttpClient; //导入依赖的package包/类
public StreamingMarketQuote() throws ModelException
{
	client.setThreadPool(new QueuedThreadPool(250));
	client.setConnectorType(HttpClient.CONNECTOR_SELECT_CHANNEL);
	client.setMaxConnectionsPerAddress(500); // max 200 concurrent connections to every address
	try
	{
		client.start();
	}
	catch (Exception e)
	{
		throw new ModelException("Start HTTP Client", e);
	}
}