码迷,mamicode.com
首页 > 编程语言 > 详细

[javaSE] 网络编程(TCP服务端客户端互访阻塞)

时间:2016-06-01 01:23:57      阅读:201      评论:0      收藏:0      [点我收藏+]

标签:

客户端给服务端发送数据,服务端收到数据后,给客户端反馈数据

 

客户端:

获取Socket对象,new出来,构造参数:Stringip地址,int的端口号

调用Socket对象的getOutputStream()方法,获取到OutputStream对象

调用OutputStream对象的write()方法,输出流输出数据,参数:byte[]字节数组

 

调用Socket对象的getInputStream()方法,获取到InputStream对象

调用InputStream对象的read()方法,读取数据得到读取的长度,参数:byte[]字节数组

获取String对象,new出来,构造参数:byte[]字节数组,0开始,len长度

调用Socket对象的close()方法,关闭socket

 

客户端的输入流读取read()方法,是阻塞式方法,会在这里等待服务端返回数据

 

服务端:

获取ServerSocket对象,new出来,构造参数:int的端口号

调用ServerSocket对象的accept()方法,得到Socket对象

调用Socket对象的getInputStream()方法,得到输入流对象,解析输入流

调用Socket对象的getOutputStream()方法,得到输出流对象,输出数据

调用Socket对象的close()方法,关闭socket

调用ServerSocket对象的close()方法,关闭ServerSocket

 

服务端的accept()方法,是阻塞式方法,会在这里等待客户端的连接

 Server.java

import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服务端
 * 
 * @author taoshihan
 * 
 */
public class Server {
    public static void main(String[] args) throws Exception {
        ServerSocket serverSocket = new ServerSocket(10004);
//        while (true) {
            Socket socket = serverSocket.accept();
            InputStream inputStream = socket.getInputStream();

            byte[] buf = new byte[1024];
            int len = inputStream.read(buf);

            InetAddress ip = socket.getInetAddress();
            
            System.out.println("来自" + ip.getHostAddress() + "说:"
                    + new String(buf, 0, len));
            Thread.sleep(10000);//睡眠10秒钟,客户端会一直等待
            OutputStream out=socket.getOutputStream();
            out.write("我是服务端,已经收到信息".getBytes());
            
            socket.close();
            serverSocket.close();
        //}
    }
}
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;

/**
 * 客户端
 * @author taoshihan
 *
 */
public class Client {
    public static void main(String[] args) throws Exception, IOException {
        Socket socket=new Socket(InetAddress.getLocalHost(), 10004);
        OutputStream outputStream=socket.getOutputStream();
        outputStream.write("我是客户端,服务端你好".getBytes());
        
        InputStream in=socket.getInputStream();
        byte[] b=new byte[1024];
        int len=in.read(b);//这里会阻塞,等待服务端的返回
        System.out.println(new String(b,0,len));
        socket.close();
    }
}

 

Client.java

 

[javaSE] 网络编程(TCP服务端客户端互访阻塞)

标签:

原文地址:http://www.cnblogs.com/taoshihan/p/5548125.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!