基于Java語言實現(xiàn)Socket通信
成都創(chuàng)新互聯(lián)是一家集網(wǎng)站建設,南開企業(yè)網(wǎng)站建設,南開品牌網(wǎng)站建設,網(wǎng)站定制,南開網(wǎng)站建設報價,網(wǎng)絡營銷,網(wǎng)絡優(yōu)化,南開網(wǎng)站推廣為一體的創(chuàng)新建站企業(yè)，幫助傳統(tǒng)企業(yè)提升企業(yè)形象加強企業(yè)競爭力。可充分滿足這一群體相比中小企業(yè)更為豐富、高端、多元的互聯(lián)網(wǎng)需求。同時我們時刻保持專業(yè)、時尚、前沿，時刻以成就客戶成長自我，堅持不斷學習、思考、沉淀、凈化自己，讓我們?yōu)楦嗟钠髽I(yè)打造出實用型網(wǎng)站。
由于近日項目需求，需要在服務器中增加Socket通信的功能，接收硬件設備發(fā)送的心跳包和相關(guān)數(shù)據(jù)，因此又重新對Java的網(wǎng)絡編程進行了復習，根據(jù)項目的實際情況做了簡化的編程，實現(xiàn)了簡單的通信過程。
1. Socket通信原理
源IP地址和目的IP地址以及源端口號和目的端口號的組合稱為套接字。其用于標識客戶端請求的服務器和服務。
以下是通過Socket套接字實現(xiàn)客戶端與服務器端通信的示意圖：
在實際應用中，客戶端會通過訪問服務器的IP和PORT連接到服務器端，這個過程在服務器和客戶端之間創(chuàng)建一個Socket，然后通過I/O數(shù)據(jù)流實現(xiàn)數(shù)據(jù)傳輸，也就是Socket的通信過程。
2. 服務器端
服務器端模擬接收硬件設備傳輸?shù)男奶ㄒ粋€長度為10的字節(jié)數(shù)組），服務器端會獲取到心跳包以及硬件設備的地址和端口號。
重慶分公司
重慶分公司
public class Server extends Thread{
//服務器端口號
private int port;
private ServerSocket server = null;
public Server(){
//創(chuàng)建一個服務器，同時可以接收10個設備發(fā)送的數(shù)據(jù)
server = new ServerSocket(port,10);
System.out.println("Socket服務器啟動，開始接受數(shù)據(jù)");
}
@Override
public void run(){
while (true) {
Socket socket = null;
InputStream inputStream = null;
OutputStream outputStream = null;
byte[] inputData = new byte[1024];
try {
//接收Socket數(shù)據(jù)
socket = server.accept();
//獲取遠程采集機的IP和端口號
String remoteAddress = socket.getInetAddress().toString();
int remotePort = socket.getPort();
inputStream = socket.getInputStream();
//獲取傳入的數(shù)據(jù)長度
int length = inputStream.read(inputData);
//創(chuàng)建輸出流向客戶端返回信息
outputStream = socket.getOutputStream();
if (length == 10) {
//如果長度等于10，說明傳入的是心跳包
System.out.println("接收到心跳包，客戶端信息["+remoteAddress+":"+remotePort+"]");
outputStream.write("success".getBytes());
} else {
System.out.println("接收的信息有誤.");
outputStream.write("failed".getBytes());
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (inputStream != null) {
inputStream.close();
}
if (outputStream != null) {
outputStream.close();
}
if (socket != null) {
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
//省略Getter和Setter方法
}3. 客戶端
客戶端負責每隔一段時間向服務器發(fā)送一個心跳包。
public final class Client {
private String address = "";
private int port = 0;
private Socket socket = null;
private Client() {
}
private Client(String address, int port) throws IOException {
this.address = address;
this.port = port;
this.socket = new Socket(address, port);
}
public static byte[] sendCommand(String address, int port, byte[] data) {
Client client = null;
OutputStream outputStream = null;
InputStream inputStream = null;
byte[] recevie = new byte[40];
try {
client = new Client(address, port);
outputStream = client.getSocket().getOutputStream();
outputStream.write(data);
System.out.print("Send Data Success");
inputStream = client.getSocket().getInputStream();
inputStream.read(recevie);
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
inputStream.close();
outputStream.close();
client.getSocket().close();
} catch (IOException ioe) {
System.out.print("IOE when closing resource");
}
}
return recevie;
}
/**
* 測試函數(shù)
**/
public static void test() {
for (int i = 0; i < 10; i++) {
//服務器地址和IP
String address = "127.0.0.1";
int port = 9000;
//心跳包
byte[] data = "#$*beat001".getBytes();
String receive = new String(Client.sendCommand(address, port, data));
System.err.println("第" + i + "次發(fā)送心跳包" + receive);
try {
//每隔2分鐘發(fā)送一個心跳包
Thread.sleep(2 * 60 * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
//省略Getter和Setter方法
}4. 小結(jié)
目前的這種方式比較像目前共享單車的通信模式，通過心跳包來獲取Client的IP和PORT，然后Server就可以通過心跳包上傳的IP和PORT主動的向Client通信了。其他的物聯(lián)網(wǎng)項目也可以使用這樣的方式，這樣就可以實現(xiàn)主動的與物聯(lián)網(wǎng)設備的通信了，只需要規(guī)定好協(xié)議和傳送數(shù)據(jù)了。
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學習或者工作具有一定的參考學習價值，謝謝大家對創(chuàng)新互聯(lián)的支持。如果你想了解更多相關(guān)內(nèi)容請查看下面相關(guān)鏈接
