学步园

客户－服务器一对一通信

一直对Socket不是很了解,但这个确实很有用,为弄懂只能看看资料,写写事例了,下面是我仿的一些希望对大家有点帮助:

1.客户-服务器一对一通信流程图

2.服务端与客户端代码

服务端: SingleServer.java

package com.nassir.socket.server;</p> <p>import java.io.BufferedInputStream;<br /> import java.io.DataInputStream;<br /> import java.io.IOException;<br /> import java.io.OutputStream;<br /> import java.net.ServerSocket;<br /> import java.net.Socket;</p> <p>import org.apache.commons.logging.Log;<br /> import org.apache.commons.logging.LogFactory;<br /> import org.apache.log4j.PropertyConfigurator;</p> <p>/**<br /> *<br /> * @author nassir wen<br /> *<br /> */<br /> public class SingleServer {</p> <p> public SingleServer(){<br /> init();<br /> waitForClient();<br /> }</p> <p> private void init(){<br /> try {<br /> server = new ServerSocket(port);<br /> //超时值为 0 被解释为无穷大超时值<br /> server.setSoTimeout(0);<br /> //套接字在其上侦听的端口<br /> log.info("[Server listen on port:" + server.getLocalPort()+"]");<br /> } catch (IOException e) {<br /> log.error(e);<br /> }<br /> }</p> <p> private void waitForClient(){<br /> try {<br /> log.info("Wait for client...");<br /> //侦听并接受到此套接字的连接。此方法在进行连接之前一直阻塞<br /> socket = server.accept();<br /> //获取套接字绑定的本地地址<br /> log.info("Client's ip:" + socket.getLocalAddress());<br /> log.info("Client's port:" + socket.getPort());<br /> } catch (IOException e) {<br /> log.error(e);<br /> }<br /> }</p> <p> private void communicate(){<br /> try {<br /> while(!isStop){<br /> //返回此套接字的输入流<br /> inStream = new DataInputStream(new BufferedInputStream(socket.getInputStream()));<br /> //返回此套接字的输出流<br /> outStream = socket.getOutputStream();<br /> while((readline = inStream.readLine()) != null){<br /> //当客户端输入stop的时候，服务器停止运行<br /> if("stop".equals(readline)){<br /> log.info("Client want to leave...");<br /> isStop = true;<br /> break;<br /> }else{<br /> System.out.println("Client said:"+readline);<br /> int data = -1;<br /> System.out.print("Server said:");<br /> /**<br /> * 此流已打开并准备提供输入数据。<br /> * 通常，此流对应于键盘输入或者由主机环境<br /> * 或用户指定的另一个输入源<br /> */<br /> while((data=System.in.read()) != -1){<br /> outStream.write((byte)data);<br /> /*<br /> * 如果读到的data是换行符 这里 '/n' 是字符，<br /> * 转换成整型数值后与data进行比较<br /> */<br /> if(data == '/n'){<br /> /**<br /> * 刷新此输出流并强制写出所有缓冲的输出字节。<br /> * flush 的常规协定是：如果此输出流的实现已经缓冲了以前写入的任何字节，<br /> * 则调用此方法指示应将这些字节立即写入它们预期的目标。<br /> * 如果此流的预期目标是由基础操作系统提供的一个抽象（如一个文件），<br /> * 则刷新此流只能保证将以前写入到流的字节传递给操作系统进行写入，<br /> * 但不保证能将这些字节实际写入到物理设备（如磁盘驱动器）。<br /> */<br /> outStream.flush();<br /> break;<br /> }<br /> }<br /> }<br /> }<br /> }<br /> } catch (IOException e) {<br /> log.error(e);<br /> }finally{<br /> try {<br /> inStream.close();<br /> outStream.close();<br /> socket.close();<br /> log.info("Server closed!");<br /> } catch (IOException e) {<br /> log.error(e);<br /> }<br /> System.exit(0);<br /> }<br /> }</p> <p> static public void main(String[] args) {<br /> //加裁日志文件<br /> PropertyConfigurator.configure("conf/log4j/log4j.properties");<br /> SingleServer singleServer = new SingleServer();<br /> singleServer.communicate();<br /> }</p> <p> private static Log log = LogFactory.getLog(SingleServer.class);</p> <p> private final static int port = 9000;</p> <p> private ServerSocket server = null;</p> <p> private Socket socket = null;</p> <p> //数据输入流允许应用程序以与机器无关方式<br /> //从基础输入流中读取基本 Java 数据类型。<br /> //应用程序可以使用数据输出流写入稍后由数据输入流读取的数据。<br /> private DataInputStream inStream=null;</p> <p> //OutputStream:此抽象类是表示输出字节流的所有类的超类。<br /> //输出流接受输出字节并将这些字节发送到某个接收器<br /> private OutputStream outStream=null;</p> <p> private String readline = null;</p> <p> private boolean isStop = false;</p> <p>}<br />

客户端:SingleClient.java

 package com.nassir.socket.client;</p> <p>import java.io.DataInputStream;<br /> import java.io.IOException;<br /> import java.io.OutputStream;<br /> import java.net.Socket;<br /> import java.net.UnknownHostException;</p> <p>import org.apache.commons.logging.Log;<br /> import org.apache.commons.logging.LogFactory;<br /> import org.apache.log4j.PropertyConfigurator;</p> <p>/**<br /> *<br /> * @author nassir wen<br /> *<br /> */<br /> public class SingleClient {</p> <p> public SingleClient() {<br /> init();<br /> }</p> <p> private void init() {<br /> try {<br /> // 创建通讯并且和服务端主机连接<br /> client = new Socket("127.0.0.1", 9000);<br /> } catch (UnknownHostException e) {<br /> log.error(e);<br /> } catch (IOException e) {<br /> log.error(e);<br /> }<br /> }</p> <p> private void communicate() {<br /> try {<br /> inStream = new DataInputStream(client.getInputStream());<br /> outStream = client.getOutputStream();<br /> int data = -1;<br /> while (!isStop) {<br /> System.out.print("Call server:");<br /> // 从标准输入输出接收字符并且写入系统<br /> while ((data = System.in.read()) != -1) {<br /> outStream.write((byte) data);<br /> if (data == '/n') {<br /> outStream.flush();<br /> // 将程序阻塞，直到回答信息被接收到后将他们显示在标准输出上<br /> responseline = inStream.readLine();<br /> if(responseline == null || "".equals(responseline)){<br /> isStop = true;<br /> break;<br /> }<br /> System.out.println("Server said:" + responseline);<br /> System.out.print("Client said:");<br /> }<br /> }<br /> }<br /> } catch (IOException e) {<br /> log.error(e);<br /> } finally {<br /> try {<br /> inStream.close();<br /> outStream.close();<br /> client.close();<br /> log.info("Client closed!");<br /> } catch (IOException e) {<br /> log.error(e);<br /> }<br /> System.exit(0);<br /> }<br /> }</p> <p> public static void main(String[] args) {<br /> PropertyConfigurator.configure("conf/log4j/log4j.properties");<br /> SingleClient singleClient = new SingleClient();<br /> singleClient.communicate();<br /> }</p> <p> private static Log log = LogFactory.getLog(SingleClient.class);</p> <p> private Socket client = null;</p> <p> private DataInputStream inStream = null;</p> <p> private OutputStream outStream = null;</p> <p> private boolean isStop = false;</p> <p> private String responseline = null;<br /> }<br />

注意:

1.日志所须jar要导入

2.服务端先启动并确保端口没有被占用(本例port:9000)