client -- server發送過程中,涉及的輸入流輸出流:
需要注意的是:先運行服務器端,再進行客戶端。
http://blog.csdn.net/qq7342272/article/details/9698413 (值得推薦的好文)
public class SocketServer { public static void main(String[] args) {
SocketServer socketServer = new SocketServer(); socketServer.startServer(); } public void startServer() { ServerSocket serverSocket = null; Socket socket = null; try {
//1.建立一個服務器端,綁定指定端口 serverSocket = new ServerSocket(9898); System.out.println("server started.."); while (true) {
//2.等待客戶端的連接。如果有客戶端接入,則執行下面的代碼;沒有客戶端接入,在這里阻塞。 socket = serverSocket.accept();
// 如果有客戶端接入,在此方法執行客戶端和服務器數據傳輸的操作。 manageConnection(socket); } } catch (Exception e) { e.printStackTrace(); } finally { try { socket.close(); serverSocket.close(); } catch (IOException e) { e.printStackTrace(); } } } public void manageConnection(final Socket socket) { new Thread(new Runnable() { @Override public void run() { BufferedReader reader = null; BufferedWriter writer =null; try { System.out.println("client " + socket.hashCode() + " connedted");
//3.從網絡->內存 in 獲得輸入流 reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//3.從內存->網絡 out 獲得輸出流 writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())); String receivedMsg;
//4.得到客戶端發來的消息 while ((receivedMsg = reader.readLine()) != null) { System.out.println("client " + socket.hashCode() + ": " + receivedMsg);
//4.向客戶端寫出消息 writer.write("server reply: " + receivedMsg + "\n"); writer.flush(); } } catch (IOException e) { e.printStackTrace(); } finally {
//5.關閉資源 try { reader.close(); writer.close(); } catch (IOException e) { e.printStackTrace(); } } } }).start(); } }
public class SocketClient { public static void main(String[] args) { SocketClient client = new SocketClient(); client.start(); } public void start() { BufferedReader inputReader = null; BufferedReader reader = null; BufferedWriter writer = null; Socket socket = null; try {
//1.建立客戶端socket連接,指定服務器位置及端口 socket = new Socket("127.0.0.1", 9898);
//2.從網絡->內存 in reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
//2.從內存->網絡 out writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
inputReader = new BufferedReader(new InputStreamReader(System.in)); startServerReplyListener(reader); String inputContent; int count = 0;
while (!(inputContent = inputReader.readLine()).equals("bye")) {
//3.向客戶端發送消息 writer.write(inputContent); if (count % 2 ==0) { writer.write("\n"); } count++; writer.flush(); } } catch (Exception e) { e.printStackTrace(); } finally {
//4.關閉資源 try { reader.close(); writer.close(); inputReader.close(); socket.close(); } catch (IOException e) { e.printStackTrace(); } } } public void startServerReplyListener(final BufferedReader reader) { new Thread(new Runnable() { @Override public void run() { try { String response;
//3.得到客戶端發來的消息 while ((response = reader.readLine()) != null) { System.out.println(response); } } catch (IOException e) { e.printStackTrace(); } } }).start(); } }