网络编程-1

一、服务端

public class SocketServer implements Runnable {

    //端口
    private final int port;
    
    private ServerSocket ss;
    
    /**
     * 
     */
    public SocketServer(int port) {
        this.port = port;
    }
    

    public void server(){
//        socket(AF_INET,SOCK_STREAM,IPPOTO_TCP);
        try {
            // 服务端阻塞接收客户端请求
            Socket s = ss.accept();
            //输入流封装
            DataInputStream din = new DataInputStream(s.getInputStream());
            //数据接受
            String req = din.readUTF();
            System.out.println("服务端请求数据："+req);
            //输出流封装
            DataOutputStream dou = new DataOutputStream(s.getOutputStream());
            String s1 = "收到,收到。我是08";
            //数据发送
            dou.writeUTF(s1);
            //刷出数据
            dou.flush();
            //关闭流和socket
            dou.close();
            din.close();

            s.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    /**
     * runnable接口
     */
    public void run() {
        // TODO Auto-generated method stub
        try {
            System.out.println("服务端启动 ,开启:"+port+"端口");
            ss = new ServerSocket(port);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        while(true){
            server();
        }
    }

    public static void main(String[] args) {
        SocketServer ss = new SocketServer(8090);
        
        Thread th = new Thread(ss);
        
        th.start();
    }
}

二、客户端

public class SocketClient{
    
    /**
     * 连接服务器
     */
    public void client(){
        Socket so = null; 
        try {
            //根据ip和端口来获取socket对象
            so = new Socket("192.168.0.114",8090);
            //根据socket对象来获取输出流
//            OutputStream out = so.getOutputStream();
            //根据socket对象来获取输出流
            DataOutputStream out = new DataOutputStream(so.getOutputStream());
            //获取本地的ip
            System.out.println(so.getLocalAddress());
            //获取本地的端口
            System.out.println(so.getLocalPort());
            //根据socket对象来获取输入流，获取目标对象的返回信息
//            InputStream out = so.getInputStream();
            DataInputStream in = new DataInputStream(so.getInputStream());
            //返回信息接D收byte数组
            byte[] b = new byte[1024];
            //定义发送过去的信息
//            String str = "bye";
            //将String类型转换为byte数组，并将编码格式设置为utf-8
//            byte[] by = str.getBytes("UTF-8");
            //通过输出流发送信息
//            out.write(by);
            out.writeUTF("我是07,我是07,收到请回复");
            //将信息刷过去
            out.flush();
            //通过输入流获取返回的信息并存储到byte数组b中
//            in.read(b);
            //直接读取utf格式
            String resp=in.readUTF();
            //打印接受的信息，并将byte数组转换为String类型，并将编码格式转换为utf-8
//            System.out.println(new String(b,"utf-8"));
            System.out.println(resp);
            //关闭输入流、输出流和socket
            in.close();
            out.close();
            so.close();
        } catch (UnknownHostException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    
    
    public static void main(String[] args) {
        SocketClient sc = new SocketClient();
        sc.client();
    }

}