TCPSocket系列二

一.单向服务器端写出及单向客户端读入

     服务器端:

import java.io.DataOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
/**
 * 一.单边服务器客户端写出和读取
 * public abstract class OutputStream extends Object 
 * implements Closeable, Flushable
 * 这个抽象类是表示字节输出流的所有类的超类。 输出流接收输出字节并将其发送到某个接收器。
 * 
 * 二.public int getPort()返回此套接字连接到的远程端口号。
 * 
 * 三.public InetAddress getInetAddress()返回套接字所连接的地址。
 */
public class TestServer {
    public static void main(String[] args) {      
        try {
            //服务器连接端口
            ServerSocket ss=new ServerSocket(8888);
            while(true){
                //连接插口
                Socket s=ss.accept();
                //通过插口写出数据
                OutputStream out=s.getOutputStream();
                //包装一层数据流管道
                DataOutputStream dat=new DataOutputStream(out);
                //以UTF的形式写出
                dat.writeUTF("俱怀逸兴壮思飞,"+s.getInetAddress()+
                        "欲上青天揽明月"+s.getPort()+"人生得意须尽欢");
                //关闭数据流,关闭插口
                dat.close();   s.close();
            }
        } catch (IOException e) {
            e.printStackTrace();
            System.out.println("程序运行异常!");
        }
        
    }
}

   客户端:

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ConnectException;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 客户端单向读取
 */
public class TestClient {
    public static void main(String[] args) {
        try {
            //确定客户端端口及服务器连接端口
            Socket s=new Socket("127.0.0.1",8888);
            //读取服务器端发送的数据
            InputStream in=s.getInputStream();
            DataInputStream dat=new DataInputStream(in);
            //以UTF的形式读取
            System.out.println(dat.readUTF());
            //关闭流和插口
            dat.close();  s.close();
        } catch (ConnectException con) {
               con.printStackTrace();
               System.out.println("服务器连接失败!");
        } catch (IOException e) {            
            e.printStackTrace();
        }
    }
}

---

二.双向向服务器端写出及单向客户端读入

 服务器端:

/**
 * 双向写出写入服务器端
 */
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;

public class TestSockServer {
    public static void main(String[] args) {
        //输入流
        InputStream in=null;
        //输出流
        OutputStream out=null;
        try {
            //服务器端监听端口
            ServerSocket ss=new ServerSocket(5888);
            //接受连接
            Socket socket=ss.accept();
            //插口获得输入和输出管道
            in=socket.getInputStream();
            out=socket.getOutputStream();
            //输出管道包装输出和输入流
            DataOutputStream dos=new DataOutputStream(out);
            DataInputStream dis=new DataInputStream(in);
            String s=null;
            if((s=dis.readUTF())!=null) {//先读入后写出
                System.out.println(s);
                //输出客户端ip地址
                System.out.println("from: "+socket.getInetAddress());
                //输出客户端端口
                System.out.println("port: "+socket.getPort());
            }
            dos.writeUTF("我是最棒哒!");
            //关闭流与插口
            dis.close(); dos.close(); socket.close();
        } catch (IOException e) {            
            e.printStackTrace();
        }
    }
}

客户端:

/**
 * 双向写出读入客户端
 */
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;

public class TestSockClient {
    public static void main(String[] args) {
        //建立输入输出流
        InputStream is=null; OutputStream out=null;
        try {//创建插口
            Socket socket=new Socket("127.0.0.1",5888);
            //插口获得流管道
            is=socket.getInputStream();
            out=socket.getOutputStream();
            //数据流管道包装
            DataInputStream dis=new DataInputStream(is);
            DataOutputStream dos=new DataOutputStream(out);
            //先写出后读入
            dos.writeUTF("hey");
            String s=null;
            if((s=dis.readUTF())!=null) {
                System.out.println(s);
                //关闭流和插口
                dos.close(); dis.close(); socket.close();
            }
        } catch (UnknownHostException e) {            
            e.printStackTrace();
        } catch (IOException e) {            
            e.printStackTrace();
        }
    }
}

先开启服务器端,再开启客户端: