java跟c++数据交互 socket java接收、发送结构体

package ndsl; import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; public class DBCAgent { private Socket socket = null; private byte[] buffer; public DBCAgent() { try { this.socket = new Socket("192.168.9.64", 8886); } catch (UnknownHostException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void recvData() throws IOException { byte[] recvHead = new byte[4]; int cForm; int cmd, length, para1, para2, para3; // read cmd socket.getInputStream().read(recvHead, 0, 4); cForm = Common.bytes2Integer(recvHead); cmd = Common.bytes2Integer(Common.toLH(cForm)); // read length socket.getInputStream().read(recvHead, 0, 4); cForm = Common.bytes2Integer(recvHead); length = Common.bytes2Integer(Common.toLH(cForm)); // read para1 socket.getInputStream().read(recvHead, 0, 4); cForm = Common.bytes2Integer(recvHead); para1 = Common.bytes2Integer(Common.toLH(cForm)); // read para2 socket.getInputStream().read(recvHead, 0, 4); cForm = Common.bytes2Integer(recvHead); para2 = Common.bytes2Integer(Common.toLH(cForm)); // read para3 socket.getInputStream().read(recvHead, 0, 4); cForm = Common.bytes2Integer(recvHead); para3 = Common.bytes2Integer(Common.toLH(cForm)); byte[] recvData = new byte[length]; // read data socket.getInputStream().read(recvData, 0, length); String DataStr = new String(recvData); System.out.println(DataStr); } public boolean sendData(String data) { byte[] temp = null; MsgHeader header = new MsgHeader(); header.setLength(data.length()); this.buffer = new byte[data.length() + 20]; // add cmd temp = Common.toLH(Protocol.PORTAL_DBC_INSTALLSYSTEM); System.arraycopy(temp, 0, buffer, 0, 4); // add lenght temp = Common.toLH(header.getLength()); System.arraycopy(temp, 0, buffer, 4, 4); // add para1 temp = Common.toLH(header.getPara1()); System.arraycopy(temp, 0, buffer, 8, 4); // add para2 temp = Common.toLH(header.getPara2()); System.arraycopy(temp, 0, buffer, 12, 4); // add para3 temp = Common.toLH(header.getPara3()); System.arraycopy(temp, 0, buffer, 16, 4); System.arraycopy(data.getBytes(), 0, buffer, 20, data.length()); try { socket.getOutputStream().write(this.buffer); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return true; } }