Java에서 Socket을 사용하여 통신 클라이언트를 구현하는 코드를 작성하는 방법

구체적인 클라이언트 코드는 다음과 같습니다:

<ol class=" list-paddingleft-2">
<li><p>import java.net.*;  </p></li>
<li><p>import java.io.*;  </p></li>
<li><p>import org.apache.log4j.Logger;  </p></li>
<li><p>public class SocketClient {  </p></li>
<li><p>static Logger log = Logger.getLogger(SocketClient.class.<br>getName()); //日志记录信息  </p></li>
<li><p>private String hostName;  </p></li>
<li><p>private int portNum;  </p></li>
<li><p>private int delaySecond; // 发文接收返回报文延时  </p></li>
<li><p>public SocketClient() {  </p></li>
<li><p>this.hostName = "192.168.0.1";  </p></li>
<li><p>this.portNum = 7000;  </p></li>
<li><p>this.delaySecond = 50000;  </p></li>
<li><p>pFileOp = null;  </p></li>
<li><p>}  </p></li>
<li><p>private Socket getSocket() {  </p></li>
<li><p>Socket socket = null;  </p></li>
<li><p>try {  </p></li>
<li><p>socket = new Socket(hostName, portNum);  </p></li>
<li><p>} catch (UnknownHostException e) {  </p></li>
<li><p>System.out.println("-->未知的主机名:" + hostName + " 异常");  </p></li>
<li><p>} catch (IOException e) {  </p></li>
<li><p>System.out.println("-hostName=" + hostName + " portNum="  </p></li>
<li><p>+ portNum + "---->IO异常错误" + e.getMessage());  </p></li>
<li><p>}  </p></li>
<li><p>return socket;  </p></li>
<li><p>}  </p></li>
<li><p>public String sendMessage(String strMessage) {  </p></li>
<li><p>String str = "";  </p></li>
<li><p>String serverString = "";  </p></li>
<li><p>Socket socket;  </p></li>
<li><p>try {  </p></li>
<li><p>socket = getSocket();  </p></li>
<li><p>// socket.setKeepAlive(true);  </p></li>
<li><p>if (socket == null) { // 未能得到指定的Socket对象,Socket通讯为空  </p></li>
<li><p>return "0001";  </p></li>
<li><p>}  </p></li>
<li><p>PrintWriter out = new PrintWriter(socket.getOutputStream());  </p></li>
<li><p>//log.info("---->发送报文="+strMessage);  </p></li>
<li><p>out.println(strMessage);  </p></li>
<li><p>out.flush();  </p></li>
<li><p>BufferedReader in = new BufferedReader(new InputStreamReader(  </p></li>
<li><p>socket.getInputStream()));  </p></li>
<li><p>long sendTime = System.currentTimeMillis();  </p></li>
<li><p>long receiveTime = System.currentTimeMillis();  </p></li>
<li><p>boolean received = false; // 成功接收报文  </p></li>
<li><p>boolean delayTooLong = false;  </p></li>
<li><p>serverString = null;  </p></li>
<li><p>while (!received && !delayTooLong) {  </p></li>
<li><p>if (socket.getInputStream().available() > 0) {  </p></li>
<li><p>// serverString = in.readLine();  </p></li>
<li><p>char tagChar[];  </p></li>
<li><p>tagChar = new char[1024];  </p></li>
<li><p>int len;  </p></li>
<li><p>String temp;  </p></li>
<li><p>String rev = "";  </p></li>
<li><p>if ((len = in.read(tagChar)) != -1) {  </p></li>
<li><p>temp = new String(tagChar, 0, len);  </p></li>
<li><p>rev += temp;  </p></li>
<li><p>temp = null;  </p></li>
<li><p>}  </p></li>
<li><p>serverString = rev;  </p></li>
<li><p>}  </p></li>
<li><p>receiveTime = System.currentTimeMillis();  </p></li>
<li><p>if (serverString != null)  </p></li>
<li><p>received = true; // 字符串不为空，接收成功  </p></li>
<li><p>if ((receiveTime - sendTime) > delaySecond)  </p></li>
<li><p>delayTooLong = true; // 接收等待时间过长，超时  </p></li>
<li><p>}  </p></li>
<li><p>in.close();  </p></li>
<li><p>out.close();  </p></li>
<li><p>str=serverString;  </p></li>
<li><p>if (delayTooLong) str="2190"; //超时标志为真，返回超时码  </p></li>
<li><p>if (!received) str ="2190";  </p></li>
<li><p>socket.close();  </p></li>
<li><p>} catch (UnknownHostException e) {  </p></li>
<li><p>log.error("---->出现未知主机错误! 主机信息=" + this.hostName + <br>" 端口号="  </p></li>
<li><p>+ this.portNum + " 出错信息=" + e.getMessage());  </p></li>
<li><p>str = "2191";  </p></li>
<li><p>// System.exit(1);  </p></li>
<li><p>} catch (IOException e) {  </p></li>
<li><p>log.error("---->出现IO异常! 主机信息=" + this.hostName + <br>" 端口号="  </p></li>
<li><p>+ this.portNum + " 出错信息=" + e.getMessage());  </p></li>
<li><p>e.printStackTrace();  </p></li>
<li><p>str = "2191";  </p></li>
<li><p>} catch (Exception e) {  </p></li>
<li><p>str="2177";  </p></li>
<li><p>log.error("---->出现未知异常" + e.getMessage());  </p></li>
<li><p>} finally {  </p></li>
<li><p>socket = null;  </p></li>
<li><p>str.trim();  </p></li>
<li><p>//log.info("--->返回的socket通讯字符串="+str);  </p></li>
<li><p>return str;  </p></li>
<li><p>}  </p></li>
<li><p>}  </p></li>
<li><p>} </p></li>
</ol>

위 내용은 Java에서 Socket을 사용하여 통신 클라이언트를 구현하는 코드를 작성하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!