在Java項(xiàng)目中使用Socket 如何實(shí)現(xiàn) 一個(gè)TCP服務(wù)端？很多新手對(duì)此不是很清楚，為了幫助大家解決這個(gè)難題，下面小編將為大家詳細(xì)講解，有這方面需求的人可以來學(xué)習(xí)下，希望你能有所收獲。
創(chuàng)新互聯(lián)長(zhǎng)期為上千客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺(tái)，與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為大悟企業(yè)提供專業(yè)的網(wǎng)站制作、成都做網(wǎng)站，大悟網(wǎng)站改版等技術(shù)服務(wù)。擁有十多年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。
1 Java Socket簡(jiǎn)介
所謂socket 通常也稱作”套接字“，用于描述IP地址和端口，是一個(gè)通信鏈的句柄。應(yīng)用程序通常通過”套接字”向網(wǎng)絡(luò)發(fā)出請(qǐng)求或者應(yīng)答網(wǎng)絡(luò)請(qǐng)求。Socket和ServerSocket類庫位于Java.NET包中。ServerSocket用于服務(wù)器端，Socket是建立網(wǎng)絡(luò)連接時(shí)使用的。在連接成功時(shí)，應(yīng)用程序兩端都會(huì)產(chǎn)生一個(gè)Socket實(shí)例，操作這個(gè)實(shí)例，完成所需的會(huì)話。對(duì)于一個(gè)網(wǎng)絡(luò)連接來說，套接字是平等的，并沒有差別，不因?yàn)樵诜?wù)器端或在客戶端而產(chǎn)生不同級(jí)別。
2 TCPServer代碼實(shí)例
重慶分公司
重慶分公司
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* TCP服務(wù)器端,單例模式
* @author xiang
*
*/
public class TCPServer implements Runnable {
private static final Logger logger = LoggerFactory.getLogger(TCPServer.class);
//成員變量/
private static TCPServer serverInstance;
private static Map socketMaps = new HashMap(); //每個(gè)客戶端連接時(shí)都會(huì)新建一個(gè)SocketThread與之對(duì)應(yīng) private static ServerSocket serverSocket; //服務(wù)器套接字
private static int serPort = 9999; //服務(wù)器端口號(hào)
private static boolean flag; //服務(wù)器狀態(tài)標(biāo)志
private static final int BUFFER_SIZE = 512; //數(shù)據(jù)接收字符數(shù)組大小
//構(gòu)造函數(shù)/
private TCPServer() {
}
/**
* 獲取實(shí)例
* @return TCPServer實(shí)例serverInstance
*/
public static TCPServer getServerInstance(){
if(serverInstance==null)
serverInstance = new TCPServer();
return serverInstance;
}
/**
* 開啟服務(wù)器
* @throws IOException
*/
public void openTCPServer() throws IOException{ if(serverSocket==null || serverSocket.isClosed()){
serverSocket = new ServerSocket(serPort);
flag = true;
}
}
/**
* 關(guān)閉服務(wù)器
* @throws IOException
*/
public void closeTCPServer() throws IOException{
flag = false; if(serverSocket!=null)
serverSocket.close();
/*for (Map.Entry entry : socketMaps.entrySet()) {
System.out.println("Key = " + entry.getKey() + ", Value = " + entry.getValue());
} */
for (SocketThread value : socketMaps.values())
value.closeConnect();
socketMaps.clear();
}
/**
* 服務(wù)器向客戶端發(fā)送數(shù)據(jù)
* @param bytes[]:待發(fā)送的字符數(shù)組
* @param key 客戶端的key,為空或""時(shí)表示數(shù)據(jù)群發(fā)
* @throws IOException
*/
public void sendMessage(String key,byte[] msgBytes){
if(key==null||key.equals("")){
for (SocketThread value : socketMaps.values())
value.sendMassage(msgBytes);
}else{
SocketThread thread = socketMaps.get(key);
if(thread!=null)
thread.sendMassage(msgBytes);
}
}
/**
* 服務(wù)器向客戶端發(fā)送數(shù)據(jù)
* @param key 客戶端的key,為空或""時(shí)表示數(shù)據(jù)群發(fā)
* @param msgStr:待發(fā)送的字符串
* @throws IOException
*/
public void sendMessage(String key,String msgStr){ byte[] sendByte = msgStr.getBytes();
if(key==null||key.equals("")){
for (SocketThread value : socketMaps.values())
value.sendMassage(sendByte);
}else{
SocketThread thread = socketMaps.get(key);
if(thread!=null)
thread.sendMassage(sendByte);
}
}
@Override
public void run() {
logger.info("服務(wù)器線程已經(jīng)啟動(dòng)"); while(true){
try {
while(flag){
logger.info("服務(wù)器線程在監(jiān)聽狀態(tài)中");
Socket socket = serverSocket.accept();
String key = socket.getRemoteSocketAddress().toString();
SocketThread thread = new SocketThread(socket,key);
thread.start();
socketMaps.put(key, thread);
logger.info("有客戶端連接："+key);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
/**
* 處理連接后的數(shù)據(jù)接收請(qǐng)求內(nèi)部類
* @author xiang
*
*/
private class SocketThread extends Thread{
private Socket socket;
private String key;
private OutputStream out;
private InputStream in;
//構(gòu)造函數(shù)
public SocketThread(Socket socket,String key) {
this.socket = socket;
this.key = key;
}
/**
* 發(fā)送數(shù)據(jù)
* @param bytes
* @throws IOException
*/
public void sendMassage(byte[] bytes){
try {
if(out==null)
out = socket.getOutputStream();
out.write(bytes);
} catch (Exception e) {
e.printStackTrace();
try {
closeConnect();
} catch (IOException e1) {
e1.printStackTrace();
}
socketMaps.remove(key);
}
}
/**
* 關(guān)閉連接，釋放資源
* @throws IOException
*/
public void closeConnect() throws IOException{
if(out!=null) out.close();
if(in!=null) in.close();
if(socket!=null && socket.isConnected()) socket.close();
}
@Override
public void run() {
byte[] receivBuf = new byte[BUFFER_SIZE];
int recvMsgSize;
try {
in = socket.getInputStream();
out = socket.getOutputStream();
while ((recvMsgSize = in.read(receivBuf)) != -1) {
String receivedData = new String(receivBuf, 0, recvMsgSize);
System.out.println("Reverve form[port" + socket.getPort() + "]:" + receivedData);
System.out.println("Now the size of socketMaps is" + socketMaps.size());
/**************************************************************
*
* 接收數(shù)據(jù)后的處理過程
*
**************************************************************/
}
// response to client
byte[] sendByte = "The Server has received".getBytes();
// out.write(sendByte, 0, sendByte.length);
out.write(sendByte);
System.out.println("To Cliect[port:" + socket.getPort() + "] 回復(fù)客戶端的消息發(fā)送成功");
closeConnect();
socketMaps.remove(key);
} catch (Exception e) {
e.printStackTrace();
try {
closeConnect();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
//////////////
public int getport(){
return socket.getPort();
}
}
//. end SocketThread
} 看完上述內(nèi)容是否對(duì)您有幫助呢？如果還想對(duì)相關(guān)知識(shí)有進(jìn)一步的了解或閱讀更多相關(guān)文章，請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道，感謝您對(duì)創(chuàng)新互聯(lián)的支持。
