代碼如下:
package com.neusoft.edu.socket;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服務器端代碼
* 獲取客戶端發送的信息,顯示并且返回對應的回復
* 1、創建ServerSocket對象
* 2、調用accept方法獲取客戶端連接
* 3、使用輸入流讀取客戶端發送的數據
* 4、使用輸出流向客戶端寫入數據
* 5、關閉對應的對象
* @author L
*
*/
public class ChatServer {
/**
* @param args
*/
public static void main(String[] args) {
try {
//1、創建ServerSocket對象,8875為自定義端口號
ServerSocket server = new ServerSocket(8857);
//簡單提示
System.out.println("等待客戶端連接……");
//2、獲取客戶端連接
Socket client = server.accept();
//獲取客戶端的相關信息
System.out.println(client.getInetAddress().getHostAddress() + "連接上來了……");
//3.1、定義輸入流和輸出流對象
BufferedReader in = new BufferedReader(
new InputStreamReader(
client.getInputStream()));
//用來獲取從控制臺輸入的數據,將該數據發送給客戶端
BufferedReader inByServer = new BufferedReader(
new InputStreamReader(System.in));
PrintWriter out = new PrintWriter(client.getOutputStream(), true);
//讀取到的數據
String data = null;
String answer = null;
//循環和客戶端進行通信
do
{
//3.2、讀取客戶端發送的數據
data = in.readLine();
//在服務器端顯示讀取到的數據
System.out.println("客戶端發送信息:" + data);
//獲取服務器端要發送給客戶端的信息
System.out.print("服務器端回復客戶端:");
answer = inByServer.readLine();
//3.3、將數據寫入到客戶端
out.println(answer);
out.flush();
}while(!"bye".equals(data));
//4、關閉相關資源
out.flush();
in.close();
inByServer.close();
out.close();
//關閉Socket對象
client.close();
server.close();
System.out.println("服務器端關閉……");
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
復制代碼代碼如下:
package com.neusoft.edu.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;
/**
* 聊天客戶端
* 1、創建Socket對象
* 2、寫入數據
* 3、讀取從服務器端發來的數據
* 4、關閉
* @author L
*
*/
public class ChatClient {
/**
* @param args
*/
public static void main(String[] args) {
try {
//1、創建Socket對象,("192.168.1.107", 8857)分別為主機IP和端口號,兩個類端口號要一致
Socket client = new Socket("192.168.1.107", 8857);
//2.1、創建輸入流和輸出流對象
BufferedReader in = new BufferedReader(
new InputStreamReader(
client.getInputStream()));
PrintWriter out = new PrintWriter(client.getOutputStream(), true);
BufferedReader inByClient = new BufferedReader(
new InputStreamReader(System.in));
//服務器端發送的數據
String data = null;
//客戶端向服務器端寫入的數據
String answer = null;
do
{
//2.2、客戶端的讀寫操作
System.out.print("你說:");
//獲取要發送給服務器端的數據
answer = inByClient.readLine();
//向服務器端寫入數據
out.println(answer);
out.flush();
//獲取服務器端發送的數據
data = in.readLine();
//輸出從服務器端獲取的數據
System.out.println("服務器端返回信息是:" + data);
}while(!"bye".equals(data));
//3、關閉
in.close();
out.close();
inByClient.close();
client.close();
System.out.println("客戶端關閉……");
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}