Socket 通常也稱作“套接字”，Java如何通過Socket實現TCP服務端？下面本站小編帶大家一起來看看詳細內容，希望對大家有所幫助!想了解更多相關資訊請持續關注我們應屆畢業生考試網!
1 Java Socket簡介
所謂socket 通常也稱作”套接字“，用於描述IP地址和埠，是一個通訊鏈的控制代碼。應用程式通常通過”套接字”向網路發出請求或者應答網路請求。Socket和ServerSocket類庫位於包中。ServerSocket用於伺服器端，Socket是建立網路連線時使用的。在連線成功時，應用程式兩端都會產生一個Socket例項，操作這個例項，完成所需的會話。對於一個網路連線來說，套接字是平等的，並沒有差別，不因為在伺服器端或在客戶端而產生不同級別。
2 TCPServer程式碼例項
import ception;
import tStream;
import utStream;
import erSocket;
import et;
import ;
import Map;
import ;
import er;
import erFactory;
/**
* TCP伺服器端,單例模式
* @author xiang
*
*/
public class TCPServer implements Runnable {
private static final Logger logger = ogger(s);
//成員變數/
private static TCPServer serverInstance;
private static Map<String, SocketThread> socketMaps = new HashMap<String,SocketThread>(); //每個客戶端連線時都會新建一個SocketThread與之對應 private static ServerSocket serverSocket; //伺服器套接字
private static int serPort = 9999; //伺服器埠號
private static boolean flag; //伺服器狀態標誌
private static final int BUFFER_SIZE = 512; //資料接收字元陣列大小
//建構函式/
private TCPServer() {
}
/**
* 獲取例項
* @return TCPServer例項serverInstance
*/
public static TCPServer getServerInstance(){
if(serverInstance==null)
serverInstance = new TCPServer();
return serverInstance;
}
/**
* 開啟伺服器
* @throws IOException
*/
public void openTCPServer() throws IOException{ if(serverSocket==null || osed()){
serverSocket = new ServerSocket(serPort);
flag = true;
}
}
/**
* 關閉伺服器
* @throws IOException
*/
public void closeTCPServer() throws IOException{
flag = false; if(serverSocket!=null)
e();
/*for (y<String, SocketThread> entry : ySet()) {
tln("Key = " + ey() + ", Value = " + alue());
} */
for (SocketThread value : es())
eConnect();
r();
}
/**
* 伺服器向客戶端傳送資料
* @param bytes[]:待發送的字元陣列
* @param key 客戶端的key,為空或""時表示資料群發
* @throws IOException
*/
public void sendMessage(String key,byte[] msgBytes){
if(key==null||ls("")){
for (SocketThread value : es())
Massage(msgBytes);
}else{
SocketThread thread = (key);
if(thread!=null)
Massage(msgBytes);
}
}
/**
* 伺服器向客戶端傳送資料
* @param key 客戶端的`key,為空或""時表示資料群發
* @param msgStr:待發送的字串
* @throws IOException
*/
public void sendMessage(String key,String msgStr){ byte[] sendByte = ytes();
if(key==null||ls("")){
for (SocketThread value : es())
Massage(sendByte);
}else{
SocketThread thread = (key);
if(thread!=null)
Massage(sendByte);
}
}
@Override
public void run() {
("伺服器執行緒已經啟動"); while(true){
try {
while(flag){
("伺服器執行緒在監聽狀態中");
Socket socket = pt();
String key = emoteSocketAddress()ring();
SocketThread thread = new SocketThread(socket,key);
t();
(key, thread);
("有客戶端連線："+key);
}
} catch (Exception e) {
tStackTrace();
}
}
}
/**
* 處理連線後的資料接收請求內部類
* @author xiang
*
*/
private class SocketThread extends Thread{
private Socket socket;
private String key;
private OutputStream out;
private InputStream in;
//建構函式
public SocketThread(Socket socket,String key) {
et = socket;
= key;
}
/**
* 傳送資料
* @param bytes
* @throws IOException
*/
public void sendMassage(byte[] bytes){
try {
if(out==null)
out = utputStream();
e(bytes);
} catch (Exception e) {
tStackTrace();
try {
closeConnect();
} catch (IOException e1) {
tStackTrace();
}
ve(key);
}
}
/**
* 關閉連線，釋放資源
* @throws IOException
*/
public void closeConnect() throws IOException{
if(out!=null) e();
if(in!=null) e();
if(socket!=null && nnected()) e();
}
@Override
public void run() {
byte[] receivBuf = new byte[BUFFER_SIZE];
int recvMsgSize;
try {
in = nputStream();
out = utputStream();
while ((recvMsgSize = (receivBuf)) != -1) {
String receivedData = new String(receivBuf, 0, recvMsgSize);
tln("Reverve form[port" + ort() + "]:" + receivedData);
tln("Now the size of socketMaps is" + ());
/**************************************************************
*
* 接收資料後的處理過程
*
**************************************************************/
}
// response to client
byte[] sendByte = "The Server has received"ytes();
// e(sendByte, 0, th);
e(sendByte);
tln("To Cliect[port:" + ort() + "] 回覆客戶端的訊息傳送成功");
closeConnect();
ve(key);
} catch (Exception e) {
tStackTrace();
try {
closeConnect();
} catch (IOException e1) {
tStackTrace();
}
}
}
//////////////
public int getport(){
return ort();
}
}
//. end SocketThread
}
