很多時候在javaweb項目中我們需要用到Socket通信來實現功能，在web中使用Socket我們需要建立一個監聽程序，在程序啟動時，啟動socket監聽。我們的應用場景是在java項目中，需要外接如一個硬件設備，通過tcp通信，獲取設備傳上來的數據，并對數據做回應。
先看一下web的監聽代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
|
import javax.servlet.ServletContextEvent;import javax.servlet.ServletContextListener;public class AttendSocetListener implements ServletContextListener{private SocketThread socketThread;public void contextDestroyed(ServletContextEvent arg) { if(null!=socketThread && !socketThread.isInterrupted()) { socketThread.closeSocketServer(); socketThread.interrupt(); } } @Overridepublic void contextInitialized(ServletContextEvent arg) { // TODO Auto-generated method stub if(null==socketThread) { //新建線程類 socketThread=new SocketThread(null); //啟動線程 socketThread.start(); } } } |
創建線程：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
|
import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.List;public class SocketThread extends Thread{private ServerSocket serverSocket = null; public SocketThread(ServerSocket serverScoket){ try { if(null == serverSocket){ this.serverSocket = new ServerSocket(); System.out.println("socket start"); } } catch (Exception e) { System.out.println("SocketThread創建socket服務出錯"); e.printStackTrace(); } } public void run(){ while(true){ try { if(serverSocket==null){break;}else if(serverSocket.isClosed()){break;}Socket socket = serverSocket.accept(); if(null != socket && !socket.isClosed()){ //處理接受的數據 Thread t = new Thread(new SocketOperate(socket)); t.start(); }else{break;}}catch (Exception e) { System.out.println("SocketThread創建socket服務出錯"); e.printStackTrace(); } } } public void closeSocketServer(){ try { if(null!=serverSocket && !serverSocket.isClosed()) { serverSocket.close(); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } |
處理接受到的數據：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.io.OutputStream;import java.net.Socket;public class SocketOperate implements Runnable { private Socket socket; //該線程所處理的Socket所對應的輸入流 BufferedReader br = null; String str = null; String content = null; InputStreamReader reader=null; public SocketOperate(Socket socket) throws IOException { this.socket = socket; reader = new InputStreamReader(this.socket.getInputStream(),"utf-"); br = new BufferedReader(reader); } @Overridepublic void run() { try{ // 采用循環不斷從Socket中讀取客戶端發送過來的數據 while (true) { content = readFromClient(); System.out.println(content);if (content == null) { break; } OutputStream os = socket.getOutputStream(); os.write(("RES, OK,<年班,小明>, ,#" + "\n").getBytes("utf-")); os.flush();} } catch (IOException e) { e.printStackTrace(); } } //定義讀取客戶端數據的方法 private String readFromClient() { try{ str = br.readLine(); return str; } //如果捕捉到異常，表明該Socket對應的客戶端已經關閉 catch (IOException e) { try {br.close();reader.close();socket.close();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();} } return null; } } |
客戶端代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
packageimport java.io.*;import java.net.*;public class TalkClient {public static void main(String args[]) throws UnknownHostException, IOException {Socket socket=new Socket("...",);PrintWriter os=new PrintWriter(socket.getOutputStream());BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));int i=;while(socket.isConnected()){os.print("BEAT,,,,.,,#"+"\n");os.flush();System.out.println("Client:"+i);System.out.println("Server:"+is.readLine());i++;} //繼續循環os.close(); //關閉Socket輸出流is.close(); //關閉Socket輸入流socket.close(); //關閉Socket}} |
以上所述是小編給大家介紹的Java Web項目中使用Socket通信多線程、長連接的方法，希望對大家有所幫助！
