java的socket请求和响应方式
作者:zhao_854093140
这篇文章主要介绍了java的socket请求和响应方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
java的socket请求和响应
创建一个socket的server端
public class demo { public static void main(String[] args) throws Exception{ // 监听指定的端口 int port = 55533; ServerSocket server = new ServerSocket(port); // server将一直等待连接的到来 System.out.println("server将一直等待连接的到来"); Socket socket = server.accept(); // 建立好连接后,从socket中获取输入流,并建立缓冲区进行读取 InputStream inputStream = socket.getInputStream(); byte[] bytes = new byte[1024]; int len; StringBuilder sb = new StringBuilder(); //只有当客户端关闭它的输出流的时候,服务端才能取得结尾的-1 while ((len = inputStream.read(bytes)) != -1) { // 注意指定编码格式,发送方和接收方一定要统一,建议使用UTF-8 sb.append(new String(bytes, 0, len, "UTF-8")); } System.out.println("get message from client: " + sb); OutputStream outputStream = socket.getOutputStream(); outputStream.write("客户端,我收到信息了".getBytes("UTF-8")); inputStream.close(); outputStream.close(); socket.close(); server.close(); } }
再创建一个socket的client端
@Slf4j public class demo1 { public static void main(String[] args) throws Exception { String serverIP = "127.0.0.1"; int port = 55533; int timeOut = 10000; String data = "<?xml version=\"1.0\" encoding=\"UTF-8\" ?>\n" + "<SERVICE>\n" + " <prcscd>mbr128</prcscd>\n" + " <servtp>MBL</servtp>\n" + " <datasq>CNT2018092500000000001</datasq>\n" + " <servsq>20180206000000000001</servsq>\n" + " <userid>0170901</userid>\n" + " <brchno>017001</brchno>\n" + " <servdt>20180925</servdt>\n" + " <servti>165125</servti>\n" + " <ipaddr>10.28.25.30</ipaddr>\n" + " <mac>D4-BE-D9-A2-39-EF</mac>\n" + " <acctno>100633778400041</acctno>\n" + "</SERVICE>"; // 与服务端建立连接 Socket socket = new Socket(serverIP, port); //设置超时时间 socket.setSoTimeout(timeOut); // 建立连接后获得输出流 OutputStream outputStream = socket.getOutputStream(); socket.getOutputStream().write(data.getBytes("UTF-8")); //通过shutdownOutput高速服务器已经发送完数据,后续只能接受数据 socket.shutdownOutput(); InputStream inputStream = socket.getInputStream(); byte[] bytes = new byte[1024]; int len; StringBuilder sb = new StringBuilder(); while ((len = inputStream.read(bytes)) != -1) { //注意指定编码格式,发送方和接收方一定要统一,建议使用UTF-8 sb.append(new String(bytes, 0, len,"UTF-8")); } System.out.println("收到响应报文: " + sb); inputStream.close(); outputStream.close(); socket.close(); } }
首先运行server端,然后再运行client端
这个时候看控制的打印
先看server端的控制台,这时收到了clietn端发来的信息
然后再看client端,看看server的返回信息是否有接收到
这样,一个socket的请求就结束了,这么的demo中的代码可以直接复用,只需将ip,port还有超时时间换了即可
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。