建站
咨詢
售后
建站咨詢
新聞中心
Java實(shí)現(xiàn)服務(wù)器監(jiān)聽，接收并處理請(qǐng)求
創(chuàng)新互聯(lián)一直通過網(wǎng)站建設(shè)和網(wǎng)站營(yíng)銷幫助企業(yè)獲得更多客戶資源。 以"深度挖掘，量身打造，注重實(shí)效"的一站式服務(wù)，以網(wǎng)站建設(shè)、成都做網(wǎng)站、移動(dòng)互聯(lián)產(chǎn)品、成都全網(wǎng)營(yíng)銷服務(wù)為核心業(yè)務(wù)。10多年網(wǎng)站制作的經(jīng)驗(yàn)，使用新網(wǎng)站建設(shè)技術(shù)，全新開發(fā)出的標(biāo)準(zhǔn)網(wǎng)站，不但價(jià)格便宜而且實(shí)用、靈活，特別適合中小公司網(wǎng)站制作。網(wǎng)站管理系統(tǒng)簡(jiǎn)單易用，維護(hù)方便，您可以完全操作網(wǎng)站資料，是中小公司快速網(wǎng)站建設(shè)的選擇。
在網(wǎng)絡(luò)編程中，服務(wù)器監(jiān)聽是一個(gè)重要的環(huán)節(jié)，服務(wù)器需要監(jiān)聽客戶端的連接請(qǐng)求，接收數(shù)據(jù)并將其傳遞給相應(yīng)的處理程序，本文將介紹如何使用Java實(shí)現(xiàn)服務(wù)器監(jiān)聽，接收并處理請(qǐng)求。
1、創(chuàng)建ServerSocket對(duì)象
我們需要?jiǎng)?chuàng)建一個(gè)ServerSocket對(duì)象，用于監(jiān)聽客戶端的連接請(qǐng)求，ServerSocket類位于java.net包中，它的構(gòu)造方法接受一個(gè)整數(shù)參數(shù)，表示端口號(hào)，我們可以創(chuàng)建一個(gè)監(jiān)聽8080端口的ServerSocket對(duì)象：
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、接收客戶端連接
當(dāng)有客戶端連接到服務(wù)器時(shí)，ServerSocket對(duì)象的accept()方法會(huì)返回一個(gè)新的Socket對(duì)象，用于與客戶端通信，我們可以使用一個(gè)循環(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、處理客戶端請(qǐng)求
當(dāng)接收到客戶端連接后，我們需要為每個(gè)客戶端連接創(chuàng)建一個(gè)新的線程，以便并發(fā)處理多個(gè)客戶端的請(qǐng)求，我們可以使用Thread類或Runnable接口來實(shí)現(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類負(fù)責(zé)處理客戶端的請(qǐng)求：
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ù)器和資源
網(wǎng)頁題目：java監(jiān)聽服務(wù)器端口
轉(zhuǎn)載來源：http://m.5511xx.com/article/cohdsho.html
