当前位置: 安卓之星 -> Java开发 -> Java网络编程(二) 连续发送数据

Java网络编程(二) 连续发送数据

作者:网络 发表于: 2016-09-22 点击: 646 次

有了建立连接的基础后,接下来尝试连续地发送和接收数据。

对于发送端比较好理解,有数据时就可以发送出去。对于接收端,就需要一直监听是否有数据发送过来。一个基本的方法就是使用 while(true) 循环不断去 read,考虑到效率问题如果对延时没那么高要求的话,可以适当 sleep。

下面是升级的 Server 端代码,这里改为使用 BufferedReader 来读取字符串的数据。

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;

public class ServerSocketTest {
    public static void main(String[] args) throws IOException, InterruptedException {
        ServerSocket serverSocket = new ServerSocket(10000);
        Socket socket = serverSocket.accept();
        System.out.println("Connected: " + socket.getRemoteSocketAddress());

        InputStream is = socket.getInputStream();
        InputStreamReader isr = new InputStreamReader(is);
        BufferedReader br = new BufferedReader(isr);

        while (true) {
            try {
                String line = null;
                while ((line = br.readLine()) != null) {
                    System.out.println(line);
                }
            } catch (Exception e) { // 客户端断开的情况
                System.out.println("Connection Close");
                break;
            }
            Thread.sleep(100);
        }
    }
}

客户端代码,也改为使用 BufferedWriter 写入,不断发送当前时间的字符串数据。

import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.text.SimpleDateFormat;
import java.util.Date;

public class ClientSocketTest {
    public static void main(String[] args) throws IOException, InterruptedException {
        Socket socket = new Socket("127.0.0.1", 10000);

        OutputStream os = socket.getOutputStream();
        OutputStreamWriter osw = new OutputStreamWriter(os);
        BufferedWriter bw = new BufferedWriter(osw);

        while (true) {
            String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date());
            try {
                bw.write(time); // 发送当前时间的字符串
                bw.newLine(); // 需要换行符做readLine()
                bw.flush(); 
                Thread.sleep(1000);
            } catch (Exception e) {
                System.out.println("Connection Close");
                break;
            }
        }
    }
}

运行结果如下
Connected: /127.0.0.1:56198
2016-11-22 10:22:58
2016-11-22 10:22:59
2016-11-22 10:23:00
2016-11-22 10:23:01
2016-11-22 10:23:02

相关文章

相关文章

赶快留言冒泡

  • 评论 (0)
  • 引用通告 (0)
目前还没有任何评论.
目前还没有任何Trackbacks和Pingbacks.
吐个泡浮上去.