/*
要求：建立一个客户端和一个服务端，客户端从键盘输入的小写字母传到服务端，服务端将小写字母转换为大写并返回给客户端。
*/
import java.io.*;
import java.net.*;
class Consumer
{
        public static void main(String[] args)throws Exception
        {
        Socket s=new Socket(InetAddress.getLocalHost(),1798);//  创建端点也叫套接字，并指定ip和端口
        BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
        BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
        String str=null;
        BufferedReader br1=new BufferedReader(new InputStreamReader(s.getInputStream()));
        String str1=null;
        while((str=br.readLine())!=null)
        {
                bw.write(str);
                //bw.flush();//必须得刷新，如果不刷新就存储在缓冲区里面。只有刷新才能刷出去。如果写这儿的话，下次再写的时候才会刷新
                bw.newLine();
                bw.flush();//必须在后面，不然刷新的出去了没有行结束符号。服务断不能readLine（）结束
                str1=br1.readLine();
                System.out.println(str1);
                if(str.equals("over"))
                        break;
        }
       
               
        s.close();
        bw.close();
        br.close();
        br1.close();
        }
}
class Server
{
        public static void main(String[] args) throws Exception
        {
                ServerSocket ss=new ServerSocket(1798);//创建指定端口的服务器套接字
                Socket s=ss.accept();
                BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));
                BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
                String str=null;
                while((str=br.readLine())!=null)//如果客户端不带有行分隔符就会停在这步
                {
                        System.out.println(str);
                        bw.write(str.toUpperCase());
                        bw.newLine();
                        bw.flush();
                }
        }
}

1. import java.io.BufferedReader;
   
2. import java.io.BufferedWriter;
   
3. import java.io.InputStreamReader;
   
4. import java.io.OutputStreamWriter;
   
5. import java.net.ServerSocket;
   
6. import java.net.Socket;
   
7. 
   
8. public class Server
   
9. {
   
10.         public static void main(String[] args) throws Exception
    
11.         {
    
12.                 while (true)
    
13.                 {
    
14.                         ServerSocket ss = new ServerSocket(1798);// 创建指定端口的服务器套接字
    
15.                         Socket s = ss.accept();
    
16.                         BufferedReader br = new BufferedReader(new InputStreamReader(
    
17.                                         s.getInputStream()));
    
18.                         BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(
    
19.                                         s.getOutputStream()));
    
20.                         String str = null;
    
21.                         while ((str = br.readLine()) != null)// 如果客户端不带有行分隔符就会停在这步
    
22.                         {
    
23.                                 System.out.println(str);
    
24.                                 bw.write(str.toUpperCase());
    
25.                                 bw.newLine();
    
26.                                 bw.flush();
    
27.                         }
    
28.                         br.close();
    
29.                         bw.close();
    
30.                         bw.flush();
    
31.                         ss.close();
    
32.                 }
    
33.         }
    
34. }
    

复制代码

加入循环就可以了