java socket 获得远程数据

//////////////////////////////////////////////////////////通过字节流获得数据

public class SocketClient {

 

private static String encoding = "GBK";

 

public static void main(String[] args) {

SocketClient c = new SocketClient();

c.getInfo("A2", "00000058");

 

System.exit(0);

// StringBuffer sb = new StringBuffer();

// sb.append("{1:001,2:a0045,");

// sb.delete(sb.length() - 1, sb.length());

// System.out.println(sb.toString());

}

 

/**

* 获得消息

* 

* @param 终端号

* @return

*/

public String getInfo(String queryA, String zdNum) {

System.out.println(">>>>>>>>>>>>>" + zdNum);

String str = "";

Socket socket = null;

try {

socket = new Socket("192.168.18.17", 8007);

socket.setSoTimeout(200000);

// 向服务器端第一次发送字符串

OutputStreamWriter osw = new OutputStreamWriter(socket.getOutputStream());

// 向服务器端第二次发送字符串

String strMili = queryA + "|07|123456||||" + zdNum;

// String strMili = "A1|07|123456||||00000058";

System.out.println("发送命令>>" + strMili);

 

// doc.writeUTF("A1|07|123456||||00000058");//这个会自动加长度

osw.write(strMili);

osw.flush();

 

DataInputStream input = new DataInputStream(socket.getInputStream());

byte[] buffer;

do{

buffer = new byte[input.available()];

if (buffer.length != 0){

break;

}

}while(true);

buffer = new byte[input.available()];

if (buffer.length != 0) {

System.out.println("length=" + buffer.length);

// 读取缓冲区

input.read(buffer);

// 转换字符串

str = new String(buffer);

System.out.println("内容=" + str);

}

 

// DataInputStream input = new

// DataInputStream(socket.getInputStream());

// System.out.println("dataInputStream=" + input.readLine());

 

// BufferedReader bufferReader = new BufferedReader(new

// InputStreamReader(socket.getInputStream()));

// System.out.println("bufferReader=" + bufferReader.readLine());

 

// 装饰流BufferedReader封装输入流（接收客户端的流）

// BufferedInputStream bis = new

// BufferedInputStream(socket.getInputStream());

//

// DataInputStream dis = new DataInputStream(bis);

// byte[] bytes = new byte[1]; // 一次读取一个byte

// String ret = "";

// while (dis.read(bytes) != -1) {

// ret += bytesToHexString(bytes) + " ";

// if (dis.available() == 0) { // 一个请求

// doSomething(ret);

// }

// }

 

} catch (UnknownHostException e) {

System.out.println("找不到主机");

e.printStackTrace();

} catch (IOException e) {

System.out.println("IO出错");

e.printStackTrace();

} catch (Exception e) {

e.printStackTrace();

}

if (socket != null) {

try {

socket.close();

} catch (IOException e) {

System.out.println("关闭socket_IO出错");

}

}

return str;

}

 

public static void doSomething(String ret) {

System.out.println(ret);

}

 

public static String bytesToHexString(byte[] src) {

StringBuilder stringBuilder = new StringBuilder("");

if (src == null || src.length <= 0) {

return null;

}

for (int i = 0; i < src.length; i++) {

int v = src[i] & 0xFF;

String hv = Integer.toHexString(v);

if (hv.length() < 2) {

stringBuilder.append(0);

}

stringBuilder.append(hv);

}

return stringBuilder.toString();

}

 

}

 ////////////////////////////////////////////////////////////常规客户端和服务端

 

public class SocketClient {

 

public static void main(String[] args) {

Socket socket = null;

try {

socket = new Socket("127.0.0.1", 8007);

// 向服务器端第一次发送字符串

OutputStream netOut = socket.getOutputStream();

DataOutputStream doc = new DataOutputStream(netOut);

DataInputStream in = new DataInputStream(socket.getInputStream());

// 向服务器端第二次发送字符串

doc.writeUTF("A1|07|123456||||00000058");

String res = in.readUTF();

System.out.println("接收："+res);

 

 

//doc.writeUTF("A1|01|cdyh123456|||LGK|01110109");

//res = in.readUTF();

//System.out.println("接收："+res);

 

 

 

 

 

doc.close();

in.close();

} catch (UnknownHostException e) {

e.printStackTrace();

} catch (IOException e) {

e.printStackTrace();

}

if (socket != null) {

try {

socket.close();

} catch (IOException e) {

}

}

}

}

 

 

public class SocketManager {

 

private int port = 8007;

 

/**

* @param args

* @throws IOException

*/

public static void main(String[] args) {

SocketManager manager = new SocketManager();

manager.doListen();

}

 

public void doListen() {

ServerSocket server;

try {

server = new ServerSocket(port);

//while (true) {

Socket client = server.accept();

new Thread(new SSocket(client)).start();

//}

} catch (IOException e) {

e.printStackTrace();

}

 

}

 

// 服务器进程

class SSocket implements Runnable {

 

Socket client;

 

public SSocket(Socket client) {

this.client = client;

}

 

public void run() {

DataInputStream input;

DataOutputStream output;

try {

input = new DataInputStream(client.getInputStream());

output = new DataOutputStream(client.getOutputStream());

//

String listMsg = input.readUTF();//接收

System.out.println("接收: " + listMsg);

 

output.writeUTF("A1|00|01|060100099|李良义|正常|0.00|0.00|集资二号楼三单元402|||是|否");

 

 

listMsg = input.readUTF();//接收

System.out.println("第二次接收: " + listMsg);

output.writeUTF("A1|00|01|01110109|杨立明|正常|0.00|0.00|麻纺厂西街4号楼2单元206|||否|否");

 

} catch (IOException e) {

e.printStackTrace();

}

}

}

}