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