serverthread.java

JAVA实现的SOCKET通讯源码,里面有双方制定的报文标示!

package testDzjs.yhServer.threadControl;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.IOException;
import java.net.Socket;

import testDzjs.yhServer.appInstance.QyDzjs;
import testDzjs.yhServer.appInstance.YhInterface;

/**
 * Created by IntelliJ IDEA.
 * User: Administrator
 * Date: 2005-4-16
 * Time: 8:37:12
 * To change this template use File | Settings | File Templates.
 */
public class serverThread extends Thread{

    Socket clientRequest;       //用户连接的通信套接字

    BufferedInputStream input;       //输入流

    BufferedOutputStream output;         //输出流

    long sCount = 0;
    /**
     * serverThread的构造器
     * @param s
     */
    public serverThread(Socket s,long l) {
        this.sCount = l;
        this.clientRequest=s;   //接收receiveServer传来的套接字

        try{        //初始化输入、输出流

            input = new BufferedInputStream(clientRequest.getInputStream());
            output = new BufferedOutputStream(clientRequest.getOutputStream());

        }catch(IOException e){
            System.out.println(e.getMessage());
            e.printStackTrace();
        }

    }


    /**
     * 线程的执行方法
     */
    public void run(){
        YhInterface yh ;
        yh = new QyDzjs();
//        yh = new DhDzjs();
        yh.start(clientRequest,input,output,this.sCount);

        try {
            clientRequest.close();
        } catch (IOException e) {
            e.printStackTrace();  //To change body of catch statement use File | Settings | File Templates.
        }

    }//end of run
}