QuickServer的学习研究（三）

?关于QuickServer在客户端编程如下：

客户端相关的业务类：

package com.easway.quickserver.echo;import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.io.PrintWriter;import java.io.Reader;import java.net.Socket;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;/** * 客户端业务类的实现 * @author longgangbai * */public class BussineClient   {private static final Log log = LogFactory.getLog(BussineClient.class);private Socket socket;private BufferedReader in;private int threadNum;private PrintWriter out;public BufferedReader getBufferedReader() throws IOException{Reader inputStream =new InputStreamReader(socket.getInputStream());return new BufferedReader(inputStream);}public PrintWriter getPrintWriter() throws IOException{OutputStream outputStream =socket.getOutputStream();return new PrintWriter(outputStream,true);}public BussineClient(int num){this.threadNum=num;//执行相关的业务action();}/** * 执行相关的业务的方法的信息 */public void action(){try{socket = new Socket("localhost", 4123);in = getBufferedReader();out = getPrintWriter();//写入线程编号out.println("############ ttt 000"+this.threadNum);String line=null;while((line=in.readLine())!=null){System.out.println("line ="+line);}out.close();in.close();socket.close();}catch (IOException e){e.printStackTrace();System.exit(1);}}}

?

?

客户端执行任务的线程：

package com.easway.quickserver.echo;/** * 执行业务的线程 * @author longgangbai * */public class BussineClientThread  implements  Runnable{private int threadNum;private BussineClient client;public BussineClientThread(int threadNum){this.threadNum=threadNum;   }@Overridepublic void run() { client=new BussineClient(threadNum);}}

?

?

客户端测试的代码：

package com.easway.quickserver.echo;import org.apache.commons.logging.Log;import org.apache.commons.logging.LogFactory;/*** * 测试业务客户端的服务 * @author longgangbai * */public class BussineClientTest {private static final Log log = LogFactory.getLog(BussineClientTest.class);  public static void main(String[] args) {for(int i=0;i<10;i++){log.info("Enter run l..."+i);new Thread(new BussineClientThread(i)).start();}}}

?