本文梳理一個基礎(chǔ)的java TCP消息通信，構(gòu)造一個簡單的Packet進(jìn)行傳輸，代碼如下：

• Packet

public class Packet {private String attribute;public Packet(String attr){this.attribute = attr;}public String getAttribute() {return attribute;}public void setAttribute(String attribute) {this.attribute = attribute;} }

• 服務(wù)器端代碼

public class App {private static final int PORT = 4000;public static void main(String[] args) throws IOException {ServerSocket listen = new ServerSocket(PORT);Socket client = null;while(true){client = listen.accept();new Thread(new ServerThread(client)).start();}} } public class ServerThread implements Runnable{private static final int BUFSIZE =1024;private Socket client = null;public ServerThread(Socket client){this.client = client;}@Overridepublic void run() {try {InputStream in = client.getInputStream();OutputStream out = client.getOutputStream();byte[] buffer = new byte[BUFSIZE];while (in.read(buffer) != -1) {//判斷包頭if(buffer[0] == 0x01 && buffer[1] == 0x02){byte[] tmp = new byte[BUFSIZE];int index = 0;for(int i = 2; i < buffer.length; i++){tmp[index++] = buffer[i];}Packet packet = new Packet(new String(tmp,"GB2312"));System.out.println(packet.getAttribute());}else{System.out.println("消息格式不正確");}}out.close();in.close();} catch (IOException e) {e.printStackTrace();} } }

• 客戶端代碼

public class App {private static final int PORT = 4000;private static final int BUFSIZE =1024;public static void main(String[] args) throws IOException {Socket client = new Socket("127.0.0.1", PORT);InputStream in = client.getInputStream();OutputStream out = client.getOutputStream();Packet packet = new Packet("類型參數(shù)2345");byte[] output = new byte[BUFSIZE];output[0] = 0x01;output[1] = 0x02;int index = 2;//若增加包長度字段，則可實(shí)現(xiàn)packet的分包、組包byte[] tmp1 = packet.getAttribute().getBytes();for(int i= 0; i < tmp1.length; i++){output[index++] = tmp1[i];}out.write(output);byte[] buffer = new byte[BUFSIZE];while (in.read(buffer) != -1) { System.out.println(new String(buffer, "GB2312"));}out.close();in.close();client.close();} }

轉(zhuǎn)載于:https://www.cnblogs.com/Fredric-2013/p/4580688.html

總結(jié)

以上是生活随笔為你收集整理的java 网络（socket）的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。