Java中多线程服务

/**
*
*/
package com.duoguo.socket;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

/**
* @author shyboy([e-mail])
*
*/
public class Client {

private String hostIp;// 客户端主机IP

private int hostPort;// 客户端主机端口号

private BufferedReader in;// 客户端输入流

private PrintWriter out;// 客户端输出流

/**
* 构造方法
*
* @param hostip
* ：IP地址
* @param hostPort
* ：端口号
*/
public Client(String hostip, int hostPort) {
this.hostIp = hostip;
this.hostPort = hostPort;
}

/**
* 建立连接
*/
public void setUpConnection() {
try {

Socket client = new Socket(hostIp, hostPort);

in = new BufferedReader(new InputStreamReader(client
.getInputStream()));// 客户端输入流

out = new PrintWriter(client.getOutputStream());// 客户端输出流

} catch (UnknownHostException e) {

System.out.println("找不到相应的主机！");
e.printStackTrace();

} catch (IOException e) {

System.out.println("抛出相应的流异常信息");
e.printStackTrace();

}
}

/**
* 获取文件
*
* @param fileName
* ：文件名称
* @return String
*/
public String getFile(String fileName) {
StringBuilder sb = new StringBuilder();

out.println(fileName);
out.flush();

String line = null;
try {

System.out.println("客户端连接成功！");
while ((line = in.readLine()) != null) {
sb.append(line + "\n");
}

} catch (IOException e) {

System.out.println("文件读入失败！");
e.printStackTrace();

}

return sb.toString();
}

/**
* 断开连接
*/
public void tearDownConnection() {
try {

out.close();// 关闭输出流
in.close();// 关闭输入流

} catch (IOException e) {

System.out.println("断开连接失败！");
e.printStackTrace();

}
}

/**
* @param args
*/
public static void main(String[] args) {

Client client = new Client("127.0.0.1", 9999);
client.setUpConnection();
String fileContent = client.getFile("D:\\hello.txt");
System.out.println("文件内容为：" + "\n" + fileContent);
client.tearDownConnection();

}

}

 

/**
*
*/
package com.duoguo.util;

import java.io.BufferedReader;
import java.io.FileReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

/**
* @author shyboy([e-mail])
*
*/
public class ConnectionHandler implements Runnable {

private Socket socket;

private BufferedReader in;

private PrintWriter out;

private BufferedReader fileBufferedReader;

/**
* 构造器
*
* @param socket
*/
public ConnectionHandler(Socket socket) {
this.socket = socket;
}

/*
* (non-Javadoc)
*
* @see java.lang.Runnable#run()
*/
@Override
public void run() {

try {

in = new BufferedReader(new InputStreamReader(socket
.getInputStream()));

out = new PrintWriter(socket.getOutputStream());

String line = in.readLine();
fileBufferedReader = new BufferedReader(new FileReader(line));
String value = null;

while ((value = fileBufferedReader.readLine()) != null) {
out.println(value);
}

} catch (IOException e) {

e.printStackTrace();

} finally {

try {

fileBufferedReader.close();
out.close();
in.close();

} catch (IOException e) {

e.printStackTrace();

}

}

}

}

 

/**
*
*/
package com.duoguo.socket;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import com.duoguo.util.ConnectionHandler;

/**
* @author shyboy([e-mail])
*
*/
public class MultiServer {

public int listenerPort;

/**
* 构造器
*
* @param listenerPort
* ：监听的端口号
*/
public MultiServer(int listenerPort) {
this.listenerPort = listenerPort;
}

/**
* 接受连接
*/
public void acceptConnection() {
try {

ServerSocket serverSocket = new ServerSocket(listenerPort, 5);

while (true) {
Socket socket = serverSocket.accept();
handleConnection(socket);// 处理连接
}

} catch (IOException e) {

e.printStackTrace();

}
}

/**
* 处理连接
*
* @param socket
* ：套接字
*/
public void handleConnection(Socket socket) {
new Thread(new ConnectionHandler(socket)).start();
}

/**
* @param args
*/
public static void main(String[] args) {

MultiServer multiServer = new MultiServer(9999);

multiServer.acceptConnection();// 接受连接

}

}