代码出错，请教！

蒋映辉

//一个简单聊天的程序，客户端可以给服务端发送数据，
但是服务端不可以给客户端发送数据，请各位朋友帮我修改一下，看哪里出错了，谢谢了

/*
客户端
*/
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();
}
}

黑马连家华 · 黑马连家华

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的循环读取方法
这些都是阻塞式方法
你服务端无法输入是因为在等待客户端的无止尽的输出,服务端的输入代码其实根本没有执行到

黑马连家华 · 黑马连家华

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();
      }
}
//...上边的代码怎么变那么乱...看这个好了...

乐峰 · 乐峰

/*
客户端
*/
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★ · Ｆriends★

聂峰发表于 2012-7-27 18:52
/*
客户端
*/

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

呵呵……要不你发个完整的代码给我，修改好的！

张水荣 · 张水荣

这是我之前做的，给你参考一下：

import java.awt.*;
import java.awt.event.*;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ConnectException;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
public class ChatClient extends Frame {
Socket s=null;
DataOutputStream dos=null;
DataInputStream dis=null;
TextField tf = new TextField();
TextArea ta = new TextArea();
private boolean bConnected=false;
public static void main(String[] args) {
new ChatClient().launchFrame();
}
public void launchFrame() {
setTitle("Chat Client");
setLocation(300, 300);
setSize(300, 300);
add(tf, BorderLayout.SOUTH);
add(ta, BorderLayout.NORTH);
pack();
this.addWindowListener(new WindowAdapter() {
@Override
public void windowClosing(WindowEvent e) {
// TODO Auto-generated method stub
disConnect();
System.exit(0);
}
});
tf.addActionListener(new TFListener());
setVisible(true);
connect();
new Thread(new RecvThread()).start();
}
public void connect(){
try {
s=new Socket("127.0.0.1", 8888);
dos=new DataOutputStream(s.getOutputStream());
dis=new DataInputStream(s.getInputStream());
bConnected=true;
System.out.println("connected");
} catch(ConnectException e){
System.out.println("Server refused.");
System.exit(0);
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
public void disConnect(){
try {
dis.close();
s.close();
dos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
private class TFListener implements ActionListener {
public void actionPerformed(ActionEvent e) {
String str=tf.getText().trim();
// ta.setText(str);
tf.setText("");
try {
dos.writeUTF(str);
dos.flush();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
private class RecvThread implements Runnable{
public void run() {
try{
while(bConnected){
String str=dis.readUTF();
ta.setText(ta.getText()+str+"\n");
}
}catch(SocketException e){
System.out.println("退出了");
}catch(IOException e){
e.printStackTrace();
}
}
}
}

复制代码

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.*;
import java.util.*;
public class ChatServer {
boolean bStarted = false;
ServerSocket ss = null;
List<Client> clients = new ArrayList<Client>();
public static void main(String[] args) {
new ChatServer().start();
}
public void start() {
try {
ss = new ServerSocket(8888);
bStarted = true;
System.out.println("服务器启动完成!");
} catch (IOException e) {
System.out.println("端口使用中。。。");
System.exit(0);
}
try {
while (bStarted) {
Socket s = ss.accept();
Client c = new Client(s);
new Thread(c).start();
System.out.println("a client has connected!");
clients.add(c);
}
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
ss.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
private class Client implements Runnable {
private Socket s = null;
private DataInputStream dis = null;
private DataOutputStream dos = null;
private boolean bConnected = false;
public Client(Socket s) {
this.s = s;
try {
dis = new DataInputStream(s.getInputStream());
dos = new DataOutputStream(s.getOutputStream());
bConnected = true;
} catch (IOException e) {
e.printStackTrace();
}
}
public void run() {
try {
while (bConnected) {
String str = dis.readUTF();
System.out.println(str);
for (int i = 0; i < clients.size(); i++) {
Client c = clients.get(i);
c.send(str);
}
}
} catch (EOFException e) {
System.out.println("Client closed!");
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
if (dis != null)
dis.close();
if (s != null)
s.close();
if (dos != null)
dos.close();
} catch (IOException e1) {
e1.printStackTrace();
}
}
}
public void send(String str) {
try {
dos.writeUTF(str);
} catch (IOException e) {
clients.remove(this);
System.out.println("A client exit!");
}
}
}
}

复制代码

张水荣 · 张水荣

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

张莹莹 · 张莹莹

本帖最后由张莹莹于 2012-7-27 21:09 编辑

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

客户端代码1：

客户端代码2：

服务器端代码1：

服务器端代码2：

客户端运行结果：

服务器端运行结果：

项目文件：

SocketTest.zip (6.4 KB, 下载次数: 57)

帐号		自动登录	找回密码
密码			加入黑马

代码出错，请教！

评分

7 个回复

评分

评分

评分

评分