黑马程序员技术交流社区

标题: 代码出错，请教！ [打印本页]
作者: Ｆriends★    时间: 2012-7-27 18:05
标题: 代码出错，请教！
//一个简单聊天的程序，客户端可以给服务端发送数据，
但是服务端不可以给客户端发送数据，请各位朋友帮我修改一下，看哪里出错了，谢谢了

/*
客户端
*/
import java.net.*;
import java.io.*;
class Client2Demo
{
        public static void main(String[] args) throws IOException
        {
                //首先就是不用说是建立服务
                Socket s=new Socket("LOIS",10002);
                //然后就是开始写数据
                OutputStream fos=s.getOutputStream();
                //读取键盘
                BufferedReader bufr =new BufferedReader(
                        new InputStreamReader(System.in));
                String line=null;
                while((line=bufr.readLine())!=null){
                        fos.write(line.getBytes());
                        fos.flush();
                }
                //读取服务端发的数据
                InputStream fis =s.getInputStream();
                int len=0;
                byte[] bys=new byte[1024];
                while((len=fis.read(bys))!=-1){
                        System.out.println(new String(bys,0,len));
                }
                s.close();
                bufr.close();
        }
}

/*
这个是服务端的部分
*/
import java.net.*;
import java.io.*;
class  Server2Demo
{
        public static void main(String[] args) throws IOException
        {
                //首先要做的就是建立服务端的额服务
                ServerSocket ss=new ServerSocket(10002);
                //确认是否建立连接
                Socket s=ss.accept();
                //读取数据
                InputStream ins=s.getInputStream();
                byte[] bys=new byte[1024];
                int len=0;
                while((len=ins.read(bys))!=-1){
                        System.out.println(new String(bys,0,len));
                }
                OutputStream out=s.getOutputStream();
                //然后就是写数据给客户端

                //服务端键盘没法录入数据
                BufferedReader bufr=new BufferedReader(
                        new InputStreamReader(System.in));
                String line=null;
                while((line=bufr.readLine())!=null){
                        out.write(line.getBytes());
                        out.flush();
                }
                ss.close();
                bufr.close();
        }
}




作者: 黑马连家华    时间: 2012-7-27 18:49
import java.net.*;import java.io.*;class Client2Demo {        public static void main(String[] args) throws IOException        {                //首先就是不用说是建立服务                Socket s=new Socket("127.0.0.1",10002);                //然后就是开始写数据                OutputStream fos=s.getOutputStream();                //读取键盘                BufferedReader bufr =new BufferedReader(                        new InputStreamReader(System.in));                                fos.write(bufr.readLine().getBytes());//                String line=null;//                while((line=bufr.readLine())!=null){//                        fos.write(line.getBytes());//                        fos.flush();//                }                //读取服务端发的数据                InputStream fis =s.getInputStream();                byte[] bys=new byte[1024];                int len= fis.read(bys);//                while((len=fis.read(bys))!=-1){                        System.out.println(new String(bys,0,len));//                }                s.close();                bufr.close();        }}
/*这个是服务端的部分*/
class  Server2Demo{        public static void main(String[] args) throws IOException        {                //首先要做的就是建立服务端的额服务                ServerSocket ss=new ServerSocket(10002);                //确认是否建立连接  注意这里不是确认连接 是在侦听并接收套接字的连接                Socket s=ss.accept();                //读取数据                InputStream ins=s.getInputStream();                byte[] bys=new byte[1024];                int len= ins.read(bys);                                 System.out.println(new String(bys,0,len));//                while((len=ins.read(bys))!=-1){//                        System.out.println(new String(bys,0,len));//                }                OutputStream out=s.getOutputStream();                //然后就是写数据给客户端
                //服务端键盘没法录入数据                BufferedReader bufr=new BufferedReader(                        new InputStreamReader(System.in));                                out.write(bufr.readLine().getBytes());//                String line=null;//                while((line=bufr.readLine())!=null){//                        out.write(line.getBytes());//                        out.flush();//                        //                }                ss.close();                bufr.close();        }}//你需要注意的是阻塞式方法BufferedReader 的readLine方法

键盘的录入方法
Socket的循环读取方法
这些都是阻塞式方法
你服务端无法输入是因为在等待客户端的无止尽的输出,服务端的输入代码其实根本没有执行到
作者: 黑马连家华    时间: 2012-7-27 18:52
import java.net.*;
import java.io.*;
class Client2Demo
{
        public static void main(String[] args) throws IOException
        {
                //首先就是不用说是建立服务
                Socket s=new Socket("127.0.0.1",10002);
                //然后就是开始写数据
                OutputStream fos=s.getOutputStream();
                //读取键盘
                BufferedReader bufr =new BufferedReader(
                        new InputStreamReader(System.in));
                                fos.write(bufr.readLine().getBytes());
//                String line=null;
//                while((line=bufr.readLine())!=null){
//                        fos.write(line.getBytes());
//                        fos.flush();
//                }
                //读取服务端发的数据
                InputStream fis =s.getInputStream();
                byte[] bys=new byte[1024];
                int len= fis.read(bys);
//                while((len=fis.read(bys))!=-1){
                        System.out.println(new String(bys,0,len));
//                }
                s.close();
                bufr.close();
        }
}

/*
这个是服务端的部分
*/

class  Server2Demo
{
        public static void main(String[] args) throws IOException
        {
                //首先要做的就是建立服务端的额服务
                ServerSocket ss=new ServerSocket(10002);
                //确认是否建立连接  注意这里不是确认连接 是在侦听并接收套接字的连接
                Socket s=ss.accept();
                //读取数据
                InputStream ins=s.getInputStream();
                byte[] bys=new byte[1024];
                int len= ins.read(bys);
                                 System.out.println(new String(bys,0,len));
//                while((len=ins.read(bys))!=-1){
//                        System.out.println(new String(bys,0,len));
//                }
                OutputStream out=s.getOutputStream();
                //然后就是写数据给客户端

                //服务端键盘没法录入数据
                BufferedReader bufr=new BufferedReader(
                        new InputStreamReader(System.in));
                                out.write(bufr.readLine().getBytes());
//                String line=null;
//                while((line=bufr.readLine())!=null){
//                        out.write(line.getBytes());
//                        out.flush();
//                                                break;
//                }
                ss.close();
                bufr.close();
        }
}
//...上边的代码怎么变那么乱...看这个好了...
作者: 乐峰    时间: 2012-7-27 18:52
/*
客户端
*/
import java.net.*;
import java.io.*;
class Client2Demo
{
        public static void main(String[] args) throws IOException
        {
                //首先就是不用说是建立服务
                Socket s=new Socket("LOIS",10002);
                //然后就是开始写数据
                OutputStream fos=s.getOutputStream();
                //读取键盘
                BufferedReader bufr =new BufferedReader(
                        new InputStreamReader(System.in));
                String line=null;
                while((line=bufr.readLine())!=null){
                        fos.write(line.getBytes());
                        fos.newline();
                        fos.flush();
                }
                //读取服务端发的数据
                InputStream fis =s.getInputStream();
                int len=0;
                byte[] bys=new byte[1024];
                while((len=fis.read(bys))!=-1){
                        System.out.println(new String(bys,0,len));
                }
                               bufr.close();//先关闭IO流，在关闭socket服务
                                s.close();

        }
}

/*
这个是服务端的部分
*/
import java.net.*;
import java.io.*;
class  Server2Demo
{
        public static void main(String[] args) throws IOException
        {
                //首先要做的就是建立服务端的额服务
                ServerSocket ss=new ServerSocket(10002);
                //确认是否建立连接
                Socket s=ss.accept();
                //读取数据
                InputStream ins=s.getInputStream();
                byte[] bys=new byte[1024];
                int len=0;
                while((len=ins.read(bys))!=-1){
                        System.out.println(new String(bys,0,len));
                }
                OutputStream out=s.getOutputStream();
                //然后就是写数据给客户端

                //服务端键盘没法录入数据
                BufferedReader bufr=new BufferedReader(
                        new InputStreamReader(System.in));
                String line=null;
                while((line=bufr.readLine())!=null){
                        out.write(line.getBytes());
                        out.newline();
                        out.flush();
                }
                              bufr.close();//先关闭IO流，在关闭socket服务
                              ss.close();

        }
}


作者: Ｆriends★    时间: 2012-7-27 19:38
聂峰 发表于 2012-7-27 18:52
/*
客户端
*/

不过OutputStream中没有newline()方法。

呵呵……要不你发个完整的代码给我，修改好的！
作者: 张水荣    时间: 2012-7-27 19:50
这是我之前做的，给你参考一下：
  1. import java.awt.*;
  2. import java.awt.event.*;
  3. import java.io.DataInputStream;
  4. import java.io.DataOutputStream;
  5. import java.io.IOException;
  6. import java.net.ConnectException;
  7. import java.net.Socket;
  8. import java.net.SocketException;
  9. import java.net.UnknownHostException;

  11. public class ChatClient extends Frame {
  12.         Socket s=null;
  13.         DataOutputStream dos=null;
  14.         DataInputStream dis=null;
  15.         TextField tf = new TextField();
  16.         TextArea ta = new TextArea();
  17.         private boolean bConnected=false;

  19.         public static void main(String[] args) {
  20.                 new ChatClient().launchFrame();
  21.         }

  23.         public void launchFrame() {
  24.                 setTitle("Chat Client");
  25.                 setLocation(300, 300);
  26.                 setSize(300, 300);
  27.                 add(tf, BorderLayout.SOUTH);
  28.                 add(ta, BorderLayout.NORTH);
  29.                 pack();
  30.                 this.addWindowListener(new WindowAdapter() {

  32.                         @Override
  33.                         public void windowClosing(WindowEvent e) {
  34.                                 // TODO Auto-generated method stub
  35.                                 disConnect();
  36.                                 System.exit(0);
  37.                         }

  39.                 });
  40.                 tf.addActionListener(new TFListener());
  41.                 setVisible(true);
  42.                 connect();
  43.                 new Thread(new RecvThread()).start();
  44.         }
  45.        
  46.          
  47.         public void connect(){
  48.                 try {
  49.                          s=new Socket("127.0.0.1", 8888);
  50.                          dos=new DataOutputStream(s.getOutputStream());
  51.                          dis=new DataInputStream(s.getInputStream());
  52.                          bConnected=true;
  53.                         System.out.println("connected");
  54.                 } catch(ConnectException e){
  55. System.out.println("Server refused.");
  56.                         System.exit(0);
  57.                 } catch (UnknownHostException e) {
  58.                         e.printStackTrace();
  59.                 } catch (IOException e) {
  60.                         e.printStackTrace();
  61.                 }
  62.         }
  63.         public void disConnect(){
  64.                 try {
  65.                         dis.close();
  66.                         s.close();
  67.                         dos.close();
  68.                 } catch (IOException e) {
  69.                         e.printStackTrace();
  70.                 }
  71.                
  72.         }

  74.         private class TFListener implements ActionListener {
  75.                 public void actionPerformed(ActionEvent e) {
  76.                         String str=tf.getText().trim();
  77. //                        ta.setText(str);
  78.                         tf.setText("");
  79.                         try {
  80.                                 dos.writeUTF(str);
  81.                                 dos.flush();
  82.                         } catch (IOException e1) {
  83.                                 e1.printStackTrace();
  84.                         }
  85.                 }
  86.         }

  88.         private class RecvThread implements Runnable{

  90.                 public void run() {
  91.                         try{
  92.                                 while(bConnected){
  93.                                          String str=dis.readUTF();
  94.                                          ta.setText(ta.getText()+str+"\n");
  95.                                 }
  96.                         }catch(SocketException e){
  97. System.out.println("退出了");                                
  98.                         }catch(IOException e){
  99.                                   e.printStackTrace();
  100.                         }
  101.                 }
  102.                
  103.         }
  104. }
复制代码
  1. import java.io.DataInputStream;
  2. import java.io.DataOutputStream;
  3. import java.io.EOFException;
  4. import java.io.IOException;
  5. import java.net.*;
  6. import java.util.*;

  8. public class ChatServer {

  10.         boolean bStarted = false;
  11.         ServerSocket ss = null;
  12.         List<Client> clients = new ArrayList<Client>();

  14.         public static void main(String[] args) {
  15.                 new ChatServer().start();
  16.         }

  18.         public void start() {
  19.                 try {
  20.                         ss = new ServerSocket(8888);
  21.                         bStarted = true;
  22.                         System.out.println("服务器启动完成!");
  23.                 } catch (IOException e) {
  24.                         System.out.println("端口使用中。。。");
  25.                         System.exit(0);
  26.                 }

  28.                 try {
  29.                         while (bStarted) {
  30.                                 Socket s = ss.accept();
  31.                                 Client c = new Client(s);
  32.                                 new Thread(c).start();
  33.                                 System.out.println("a client has connected!");
  34.                                 clients.add(c);
  35.                         }
  36.                 } catch (IOException e) {
  37.                         e.printStackTrace();
  38.                 } finally {
  39.                         try {
  40.                                 ss.close();
  41.                         } catch (IOException e) {
  42.                                 e.printStackTrace();
  43.                         }
  44.                 }
  45.         }

  47.         private class Client implements Runnable {
  48.                 private Socket s = null;
  49.                 private DataInputStream dis = null;
  50.                 private DataOutputStream dos = null;
  51.                 private boolean bConnected = false;

  53.                 public Client(Socket s) {
  54.                         this.s = s;
  55.                         try {
  56.                                 dis = new DataInputStream(s.getInputStream());
  57.                                 dos = new DataOutputStream(s.getOutputStream());
  58.                                 bConnected = true;
  59.                         } catch (IOException e) {
  60.                                 e.printStackTrace();
  61.                         }
  62.                 }

  64.                 public void run() {
  65.                         try {
  66.                                 while (bConnected) {
  67.                                         String str = dis.readUTF();
  68.                                         System.out.println(str);
  69.                                         for (int i = 0; i < clients.size(); i++) {
  70.                                                 Client c = clients.get(i);
  71.                                                 c.send(str);
  72.                                         }
  73.                                 }
  74.                         } catch (EOFException e) {
  75.                                 System.out.println("Client closed!");
  76.                         } catch (IOException e) {
  77.                                 e.printStackTrace();
  78.                         } finally {
  79.                                 try {
  80.                                         if (dis != null)
  81.                                                 dis.close();
  82.                                         if (s != null)
  83.                                                 s.close();
  84.                                         if (dos != null)
  85.                                                 dos.close();
  86.                                 } catch (IOException e1) {
  87.                                         e1.printStackTrace();
  88.                                 }
  89.                         }
  90.                 }

  92.                 public void send(String str) {
  93.                         try {
  94.                                 dos.writeUTF(str);
  95.                         } catch (IOException e) {
  96.                                 clients.remove(this);
  97.                                 System.out.println("A client exit!");
  98.                         }
  99.                 }

  101.         }
  102. }
复制代码
作者: 张水荣    时间: 2012-7-27 20:39
楼主的程序存在问题：
1. 读写操作没有使用两个线程。要使服务器端而客户端同时有接收与发送数据的功能，使用多线程能很好地解决问题。
2. System.in对象运行的是一个阻塞式的方法，在同一个线程中用while循环运行到它时，循环外面的程序块将不能得到运行
所以建议 Lz 使用多线程再试试。也可以参考我上面的例子进行理解。
因为时间仓促，我上面的代码没有加注释，Lz 可以运行一下看一下结果再看代码，如有看不懂的地方，可以问我的。
提醒一句，我那个例子可以运行多个客户端的！
作者: 张莹莹    时间: 2012-7-27 20:56
本帖最后由 张莹莹 于 2012-7-27 21:09 编辑

程序只要稍加修改，接收数据的部分挪到线程中即可，详细代码如下：

客户端代码1：


客户端代码2：


服务器端代码1：


服务器端代码2：


客户端运行结果：

服务器端运行结果：


项目文件：
SocketTest.zip (6.4 KB, 下载次数: 144)



欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2