java语言程序设计（第二版）李尊朝

package example16_3; import java.io.*; import java.net.*; import java.awt.*; import java.awt.event.*; import javax.swing.*; public class Server1 extends JFrame{ private JTextField enter; //创建文本框 private JTextArea display; //创建显示文本域 PrintStream output; //输出流 DataInputStream input; // 输入流 public Server1(){ super( "Server" ); //引用父类的超类 Container c=getContentPane(); enter=new JTextField(); //创建文本框对象 enter.setEnabled( false ); // 文本框不可编辑 enter.addActionListener(new ActionListener(){ //为文本框加入事件监听 public void actionPerformed(ActionEvent e ) { sendData(enter.getText()); } //将输入到文本框中的字符发送到客户端 }); c.add(enter, BorderLayout.NORTH); //定义文本框在容器中的位置 display=new JTextArea(); //创建文本域对象 c.add(new JScrollPane(display),BorderLayout.CENTER); setSize(300,150); show(); } private void sendData(String s){ //将文本框中的字符传递给客户端 try{ output.println("Server: "+s); //将文本框中的内容发送到PrintStream缓冲区中 output.flush(); //将缓冲区中的数据发送到客户端 enter.setText(""); //设置文本框的内容为“空” } catch (Exception e){ display.append("\nError writing object"); } } public void connect(){ ServerSocket server; //服务器端的Socket接口对象 Socket socket; //客户端的Socket接口对象 int counter=1; //连接数 try{ // 第1步:创建一个监听，端口是4321，最大连接数是10 server=new ServerSocket(4321,10); while(true){ // 第1步：等待一个请求 display.setText( "等待客户端的请求\n" ); socket=server.accept(); //等待客户端的请求 display.append("连接"+counter+"来自:"+socket.getInetAddress().getHostName() ); // 第3步：获得输入和输出流 output=new PrintStream(new BufferedOutputStream(socket.getOutputStream())); output.flush(); input=new DataInputStream(new BufferedInputStream(socket.getInputStream())); // 第4步：传递信息 String message="Server Connection successful!"; output.println(message); //将“message”字符串内容发送到PrintStream缓冲区中 output.flush(); //将缓冲区中的数据发送到客户端 enter.setEnabled(true); do{ try{ message=(String)input.readLine(); /*读取InputStream缓冲区中的内容，也就是服务器端输入流的内容，也就是客户端PrintStream缓冲区中的内容，这样就获得客户端传递的信息*/ display.append("\n"+message); //在文本域显示客户端传递的信息 } catch (IOException e){ display.append("Data Error"); } }while(!message.equals("Client: end")); // 第5步：拆除连接 display.append("\n关闭连接"); enter.setEnabled(false); output.close(); input.close(); socket.close(); //关闭当前客户端请求，继续监听其他客户端 ++counter; } } catch(EOFException eof){ System.out.println( "Client terminated connection" ); } catch (IOException e){ e.printStackTrace(); } } public static void main(String args[]){ Server1 app = new Server1(); app.addWindowListener(new WindowAdapter(){ public void windowClosing(WindowEvent e) { System.exit(0); } }); app.connect(); } }