我尝试了这个,但在某个地方我无法读取服务器的响应。 (响应采用 XML 格式)。
我读到由于字符串损坏,通过套接字写入需要缓冲。不知何故,当我使用 jaxb unmarshaller 时,我发现这是真的,它报告了 SAX EOF 异常,这意味着读取的 xml 不完整。
请问如何正确缓冲写入和缓冲读取?
StringBuilder sb = new StringBuilder();
sb.append("<estel>");
sb.append("<header><requesttype>").append(hd.getRequestType()).append("</requesttype></header>");
sb.append("<request>");
sb.append("<agentcode>").append(rq.getAgentCode()).append("</agentcode>");
sb.append("<pin>").append(rq.getPin()).append("</pin>");
sb.append("<destination>").append(rq.getDestination()).append("</destination>");
sb.append("<agenttransid>").append(rq.getAgentTransId()).append("</agenttransid>");
sb.append("<vendorcode>").append(rq.getVendorCode()).append("</vendorcode>");
sb.append("<amount>").append(rq.getAmount()).append("</amount>");
sb.append("<productcode>").append(rq.getProductCode()).append("</productcode>");
sb.append("<comments>").append(rq.getComments()).append("</comments>");
sb.append("<clienttype>").append(rq.getClientType()).append("</clienttype>");
sb.append("</request></estel>");
Socket socket = new Socket("41.206.23.21",7101);
OutputStream os = socket.getOutputStream();
InputStream in = socket.getInputStream();
OutputStream buf = new BufferedOutputStream(os);
out = new OutputStreamWriter(buf);
System.out.printf("\nxml is %s",sb.toString());
System.out.print("\n--------writing--to--socket-----");
out.write(sb.toString());
out.flush();
//read response
InputStream bui = new BufferedInputStream(in);
rd = new InputStreamReader(bui);
System.out.print("\nxml response"+rd.toString());
in.close();
out.close();
socket.close();
您通过套接字发送 XML,但服务器端没有应答。为了 100% 确定发生了什么,我们需要服务器代码和服务器错误消息。到目前为止,我看到两件事,你可以做:
写入和刷新XML时,可以调用
socket.shutdownOutput()
。这会向服务器发送一个 EOF,表明没有更多内容可读取。服务器应该知道的最新信息是,它必须处理 XML 并生成结果。您通过
char
的流发送 byte
的字符串。希望服务器能够像客户端发送它一样理解它。由于希望对编程并没有真正的帮助,因此您应该像这样包装输出流:Writer writer = new OutputStreamWriter(socket.shutdownOutput(), "UTF-8");
并使用 writer 进行写入和刷新。请注意,您需要在服务器端对输入流执行相同的操作(用“UTF-8”包装为 Reader)请将您的问题简化为一段显示错误的运行代码。发布一些甚至无法编译的代码并不能真正帮助理解您遇到的问题。即使将此代码放入方法中并导入 java.io 内容后,仍有 4 个(!)未声明的变量:
hd, rq, out and rd
。
帮助解决您的问题并回答您的疑问:
您不需要使用缓冲写入器,您只需确保写入您想要写入的所有内容(然后刷新或关闭流)。当然,客户端(接收者)在尝试解释数据之前必须从该流中读取字节,只要字节可用。
如果你想实现不同的协议,你当然必须读/写,直到某个标记或任何表明你的传输完成的东西。然而,对于这个问题,我假设您只想传输一组 XML 数据。
对于写入,您可以使用简单的
OutputStream
一次性写入字符串。
像这样的代码就可以完成这项工作:
StringBuilder sb = new StringBuilder();
//...
Socket socket = new Socket("41.206.23.21", 7101);
OutputStream os = socket.getOutputStream();
os.write(sb.toString().getBytes());
os.flush();
阅读该内容后,您还可以使用简单的
InputStream
。为了确保获得所有内容,通常应该读取数据并将其全部写入中间字节数组,然后可以将其转换回字符串。这样做的通用方法可能是这样的:
String read(InputStream in) throws IOException {
byte[] buffer = new byte[8192];
ByteArrayOutputStream out = new ByteArrayOutputStream();
int got;
while ((got = in.read(buffer)) > -1) {
out.write(buffer, 0, got);
}
byte[] data = out.toByteArray();
String result = new String(data);
return result;
}
请记住,此方法既不关闭流,也不处理异常。