package com.wenqier.service;

import java.net.*;
import java.io.*;

//聊天过程中新建一个专门用于发送信息的线程
class Send extends Thread {
	Socket socket;

	public Send(Socket sock) {
		this.socket = sock;
	}
	// 专门用于发送信息
	public void run() {
		DataOutputStream out;
		while (true) {
			BufferedReader input = new BufferedReader(new InputStreamReader(
					System.in));
			try {
				String str;
				str = input.readLine();
				out = new DataOutputStream(socket.getOutputStream());
				out.writeUTF(str);
			} catch (Exception e) {
			}
		}

	}
}

// 创建一个专门用于接收消息的线程
class Receive extends Thread {
	Socket socket;

	public Receive(Socket sock) {
		this.socket = sock;
	}

	public void run() {
		// 专门用于接收消息
		DataInputStream in;
		while (true) {
			try {
				in = new DataInputStream(socket.getInputStream());
				String str = in.readUTF();
				System.out.println(str);
			} catch (Exception e) {
			}
		}
	}
}

public class Service {
	// 声明ServerSocket类对象
	static ServerSocket service;

	public static void main(String[] args) {
		try {
			service = new ServerSocket(5678);

			System.out.println("服务器端.....");
			Socket client = null;

			client = service.accept();

			Send send = new Send(client);
			Receive receive = new Receive(client);
			// 打开线程
			send.start();
			receive.start();
		} catch (Exception e) {
		}
	}
}