/**
* XXXX软件有限公司
* socket:socket.Server.java
* 日期:2015年12月4日
*/
package socket;
import java.io.BufferedReader;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.StringReader;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;
/**
* Socket通信的服务端
*
* @author 王俊伟 wjw.happy.love@163.com
* @date 2015年12月4日 上午10:01:11
*/
public class Server {
public static final int PORT = 4444;// 监听的端口号 9666 4444
public static void main(String[] args) {
Server server = new Server();
server.init();
}
private void init() {
ServerSocket serverSocket = null;
try {
serverSocket = new ServerSocket(PORT);
//System.out.println(serverSocket.getInetAddress());
while (true) {
Socket client = serverSocket.accept();
// 一个客户端连接就开户两个线程处理读写
new Thread(new ReadHandlerThread(client)).start();
new Thread(new WriteHandlerThread(client)).start();
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (serverSocket != null) {
serverSocket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
/**
*
* 读客户端数据
*
* @author 王俊伟 wjw.happy.love@163.com
* @date 2016年7月21日 下午5:13:49
*/
class ReadHandlerThread implements Runnable {
private Socket client;
public ReadHandlerThread(Socket client) {
this.client = client;
}
@Override
public void run() {
BufferedReader br = null;
try {
while (true) {
// 读取客户端数据
br = new BufferedReader(new InputStreamReader(client.getInputStream()));
String reciver = br.readLine();
System.out.println("客户端发过来的内容:" + reciver);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (br != null) {
br.close();
}
if (client != null) {
client = null;
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
/**
* 处理写操作的线程
*/
class WriteHandlerThread implements Runnable {
private Socket client;
public WriteHandlerThread(Socket client) {
this.client = client;
}
@Override
public void run() {
DataOutputStream dos = null;
BufferedReader br = null;
try {
while (true) {
// 向客户端回复信息
dos = new DataOutputStream(client.getOutputStream());
//System.out.print("请输入:\t");
// 键盘录入
//br = new BufferedReader(new InputStreamReader(System.in));
String data = "TTLK" + new Random().nextInt(100);
System.out.println("发给客户端数据："+data);
StringReader in = new StringReader(data);
br = new BufferedReader(in);
String send = br.readLine();
// 发送数据
dos.writeBytes(send+"\n");   //必须写入换行符
Thread.sleep(3000);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (dos != null) {
dos.close();
}
if (br != null) {
br.close();
}
if (client != null) {
client = null;
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}