java socket實現局域網聊天
使用socket實現局域網聊天，寫這個主要是為瞭深入理解socket與信息流在網絡中的傳送過程加深理解。
代碼很簡單分為兩個類，一個服務器類，一個客戶端，運行時分別啟動兩個線程一個負責接受另一個負責發送。
整體流程是 兩臺機器分別啟動程序，一個選擇主動連接 另一個選擇被動接受，即可實現類似qq的聊天效果兩個人可以同時發送消息。
註意的事，不要在同一臺電腦上同時啟動兩個，這樣會服務端和客戶端的ip都是相同很有可能造成自己發送的消息自己接受到瞭，可以兩臺電腦或者虛擬機裡面進行。
服務端：
package com.server;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
import com.client.RunClient;
public class RunServer {
public static Socket socket=null;
/**
* 建立服務器被動連接
* @throws IOException
*/
public void startServer() throws IOException {
//服務器接收數據
ServerSocket serverSocekt=new ServerSocket(8888);
System.out.println("服務器啟動，等待連接...");
//創建客戶端線程
RunClient rc=new RunClient();
Thread rct=new Thread(rc);
rct.start();
//阻塞線程 監聽端口建立socket會話
RunServer.socket=serverSocekt.accept();
//獲取輸入留
InputStream is=socket.getInputStream();
//將字節輸入流轉換成字符輸入流
InputStreamReader isr=new InputStreamReader(is);
//將字符輸入流裝入帶緩沖的輸入流中
BufferedReader br=new BufferedReader(isr);
String str=null;
while((str=br.readLine())!=null){
System.out.print("輸出信息："+str);
}
socket.shutdownInput();
serverSocekt.close();
}
}
客戶端：
package com.client;
import java.io.BufferedWriter;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Scanner;
import com.server.RunServer;
public class RunClient implements Runnable {
@Override
public void run() {
// TODO Auto-generated method stub
Scanner input = new Scanner(System.in);
System.out.println("1、主動連接\n2、被動等待");
String sign=input.next();
switch (sign) {
case "1":
try {
System.out.println("輸入服務器IP：");
startClient(input.next());
} catch (Exception e) {
e.printStackTrace();
}
break;
case "2":
try {
startClient();
} catch (Exception e) {
e.printStackTrace();
}
break;
default:
break;
}
}
/**
* 由已經建立的socket 進行連接反向連
* @throws Exception
* @throws UnknownHostException
*/
public void startClient() throws Exception{
while(true){
try {
if(RunServer.socket!=null){
break;
}
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// 與服務器建立連接
Socket socket=new Socket(RunServer.socket.getInetAddress().getHostAddress(), 8888);
System.out.println("連接建立成功...");
//向服務器寫入流
OutputStream os=socket.getOutputStream();
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os));
Scanner input=new Scanner(System.in);
while(true){
System.out.println("輸入信息：");
bw.write(input.next());
bw.newLine();
bw.flush();
}
}
/**
* 通過IP與服務器建立連接
* @throws Exception
* @throws UnknownHostException
*/
public void startClient(String ip) throws Exception{
// 與服務器建立連接
Socket socket=new Socket(ip, 8888);
System.out.println("連接建立成功...");
//向服務器寫入流
OutputStream os=socket.getOutputStream();
BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(os));
Scanner input=new Scanner(System.in);
while(true){
bw.write(input.next());
bw.newLine();
bw.flush();
}
}
}
main：
package com.start;
import com.server.RunServer;
public class Go {
public static void main(String[] args) throws Exception {
// TODO Auto-generated method stub
RunServer rs=new RunServer();
rs.startServer();
}
}
效果：我是用虛擬機加本機
以上就是本文的全部內容，希望對大傢的學習有所幫助，也希望大傢多多支持WalkonNet。