黑马程序员技术交流社区

标题: 只学了一天的网络编程，写了一个能够聊天的简单程序，..... [打印本页]

---

作者: 18001105207    时间: 2016-9-16 22:39
标题: 只学了一天的网络编程，写了一个能够聊天的简单程序，.....
      在eclipse中，多人访问服务器程序的时候，只能有一个人和服务器聊天，是为什么？如何改进？求解
服务器程序
package server;

import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class ServerSocketDemo {

        public static void main(String[] args) throws Exception {

                ServerSocket ss = new ServerSocket(8888);
                final Scanner sc = new Scanner(System.in);
                while(true) {
                        final Socket s = ss.accept();
                        new Thread(
                                        new Runnable() {

                                                public void run() {
                                                        try {
                                                                InputStream is = s.getInputStream();
                                                                byte[] b = new byte[1024];
                                                                int len = -1;
                                                                while((len=is.read(b))!=-1) {
                                                                        System.out.println(new String(b,0,len));
                                                                }
                                                                OutputStream os = s.getOutputStream();
                                                                System.out.println("请输入回复：");
                                                                String str = sc.nextLine();
                                                                os.write(str.getBytes());
                                                                os.flush();
                                                                s.shutdownOutput();
                                                                is.close();
                                                               
                                                               
                                                               
                                                        } catch (IOException e) {
                                                                e.printStackTrace();
                                                        }
                                                }
                                               
                                        }
                                        ).start();
                }
        }

}

客户端程序：
package server;

import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.Socket;
import java.util.Scanner;

public class SocketDemo {

        public static void main(String[] args) throws Exception {

                InetAddress ip = InetAddress.getLocalHost();
               
                while(true) {
                        Socket s = new Socket("192.168.106.29",6666);
                OutputStream os = s.getOutputStream();
                Scanner sc = new Scanner(System.in);
                System.out.println("请输入聊天内容：");
                String str = sc.nextLine();
                os.write(str.getBytes());
                os.flush();
                s.shutdownOutput();
                //os.close();
                InputStream is = s.getInputStream();
                byte[] b = new byte[1024];
                int len = is.read(b);
                System.out.println(new String(b,0,len));
               
                s.close();
               
        }
        }
}

---

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

黑马程序员IT技术论坛 X3.2