建站
咨詢
售后
建站咨詢
新聞中心
Java實現(xiàn)服務(wù)器監(jiān)聽，接收并處理請求
創(chuàng)新互聯(lián)一直通過網(wǎng)站建設(shè)和網(wǎng)站營銷幫助企業(yè)獲得更多客戶資源。 以"深度挖掘，量身打造，注重實效"的一站式服務(wù)，以網(wǎng)站建設(shè)、成都做網(wǎng)站、移動互聯(lián)產(chǎn)品、成都全網(wǎng)營銷服務(wù)為核心業(yè)務(wù)。10多年網(wǎng)站制作的經(jīng)驗，使用新網(wǎng)站建設(shè)技術(shù)，全新開發(fā)出的標準網(wǎng)站，不但價格便宜而且實用、靈活，特別適合中小公司網(wǎng)站制作。網(wǎng)站管理系統(tǒng)簡單易用，維護方便，您可以完全操作網(wǎng)站資料，是中小公司快速網(wǎng)站建設(shè)的選擇。
在網(wǎng)絡(luò)編程中，服務(wù)器監(jiān)聽是一個重要的環(huán)節(jié)，服務(wù)器需要監(jiān)聽客戶端的連接請求，接收數(shù)據(jù)并將其傳遞給相應(yīng)的處理程序，本文將介紹如何使用Java實現(xiàn)服務(wù)器監(jiān)聽，接收并處理請求。
1、創(chuàng)建ServerSocket對象
我們需要創(chuàng)建一個ServerSocket對象，用于監(jiān)聽客戶端的連接請求，ServerSocket類位于java.net包中，它的構(gòu)造方法接受一個整數(shù)參數(shù)，表示端口號，我們可以創(chuàng)建一個監(jiān)聽8080端口的ServerSocket對象：
import java.net.ServerSocket;
public class Server {
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(8080);
} catch (Exception e) {
e.printStackTrace();
}
}
}
2、接收客戶端連接
當有客戶端連接到服務(wù)器時，ServerSocket對象的accept()方法會返回一個新的Socket對象，用于與客戶端通信，我們可以使用一個循環(huán)來不斷接收新的客戶端連接：
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(8080);
while (true) {
Socket socket = serverSocket.accept();
// 處理客戶端連接
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
3、處理客戶端請求
當接收到客戶端連接后，我們需要為每個客戶端連接創(chuàng)建一個新的線程，以便并發(fā)處理多個客戶端的請求，我們可以使用Thread類或Runnable接口來實現(xiàn)多線程：
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
try {
ServerSocket serverSocket = new ServerSocket(8080);
while (true) {
Socket socket = serverSocket.accept();
new Thread(new ClientHandler(socket)).start();
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
serverSocket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
ClientHandler類負責處理客戶端的請求：
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;
import org.springframework.stereotype.Component;
@Component("clientHandler") public class ClientHandler implements Runnable{ private AtomicInteger id=new AtomicInteger(0); private Socket socket; private PrintWriter writer; private BufferedReader reader; private String name; private ExecutorService pool=Executors.newCachedThreadPool(); @Override public void run(){ try{ //讀取客戶端信息 writer=new PrintWriter(socket.getOutputStream()); reader=new BufferedReader(new InputStreamReader(socket.getInputStream())); name=(reader.readLine())==null?"":reader.readLine(); System.out.println("新用戶"+name+"已上線！"); //向所有在線用戶發(fā)送消息 pool.execute(new Runnable(){ @Override public void run(){ try{ writer=new PrintWriter(socket, true); }catch (Exception e){ e.printStackTrace(); }writer.println("歡迎"+name+"加入聊天室！"); }}); //獲取用戶輸入的消息 while((msg=reader.readLine())!=null){ pool.execute(new Runnable(){ @Override public void run(){ try{ writer=new PrintWriter(socket, true); }catch (Exception e){ e.printStackTrace(); }writer.println("<>"+name+"："+msg); }}); }catch (Exception e){ e.printStackTrace(); }finally{ //關(guān)閉資源 try{ reader=null; writer=null; socket=null; }catch (Exception e){ e.printStackTrace(); }pool=null; } } } @Override public String toString(){ return "ClientHandler [id="+id+", name="+name+"]"; } } ``` 4. 關(guān)閉服務(wù)器和資源
分享文章：java監(jiān)聽服務(wù)器端口
網(wǎng)頁URL：http://www.5511xx.com/article/cohdsho.html
