网络编程-TCP程序实例（文本大写转化器）

package netTest;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

/*
 * 需求：建立一个文本转换服务器
 * 客户端给服务器发送文本，服务器会将文本转换成大写再返回给客户端
 * 而且客户端可以不断的进行文本转换，当客户端输入over时，转换结束。
 *
 *步骤： 1.建立服务
 *     2.获取键盘录入
 *    3.将数据发送给服务端
 *    4.获取服务器端返回的大写数据
 *    5.结束，关闭资源
 *    都是文本数据，可以使用字符流进行操作，同时提高效率，加入缓冲
 */
public class TcpClient {
    public static void main(String[] args) throws Exception {
        Socket s = new Socket(InetAddress.getLocalHost(),7605);
        //OutputStream out = s.getOutputStream();
        // 定义一个socket 读取流，读取服务器端返回的大写信息
        BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
        
        // 定义读取键盘数据的流对象
        BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
        
        //定义目的，将数据写入到socket输出流，发送给服务器。
        BufferedWriter bufOut = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        String line = null;
        while((line = bufr.readLine())!=null){
            if("over".equals(line)){
                break;
            }
            bufOut.write(line);
            bufOut.newLine();
            // 数据在缓冲区中没有出去
            bufOut.flush();
            //刷新后数据就出去了。
            String str = bufIn.readLine();
            System.out.println("server:"+str);
        }
        /*byte[] buf = new byte[1024];
        while(true){
            int len = bufr.read(buf);
            System.out.println(new String(buf,0,len));
        }*/
        
    }
}
/*
 * 该例子出现的问题:
 * 现象：客户端和服务器端都在莫名的等待。
 * 为什么呢？ 因为客户端和服务器端都有阻塞式的方法，这些方法没有读到结束标记，那就一直等待下去，从而导致两端
 * 都在等待。在 read里面。
 */



package netTest;

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

/*
 * 
 * 服务端：源 socket 读取流
 *     ：目的：socket 输出流
 *     文本装饰。
 */
public class TcpServer {
    public static void main(String[] args) throws IOException {
        ServerSocket ss = new ServerSocket(7605);
        while(true){
            Socket s = ss.accept();
            String ip = s.getInetAddress().getHostAddress();
            System.out.println(ip);
            // 定义一个socket 读取流，读取服务器端返回的大写信息
            BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
            //定义目的，将数据写入到socket输出流，发送给服务器。
            BufferedWriter bufOut = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
            String line = null;
            // 在读一行时实际上读到是回车前的数据，这是没有一行
            while((line = bufIn.readLine())!=null){
                System.out.println(line);
                if(line.equals("over")){
                    break;
                }
                bufOut.write(line.toUpperCase());
                // 这是结束标记这个地方很重要  。。。。。。。。。
                bufOut.newLine();
                bufOut.flush();
            }
            s.close();
            ss.close();
        }
        
    }
}