A股上市公司传智教育（股票代码 003032）旗下技术交流社区北京昌平校区

传智教育官网黑马程序员官网

 找回密码
 加入黑马

QQ登录

只需一步，快速开始

论坛首页 › 隐藏归类 › 黑马那些年 › 第13,14届JavaEE+hadoop大数据技术交流 › 正文

关于利用Socket进行网络传输的问题

© win_top1 中级黑马   /  2014-11-13 19:56  /  923 人查看  /  0 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

  1. 服务器端：
  2. import java.net.ServerSocket;
  3. import java.net.Socket;

  5. public class MainServer
  6. {
  7.         public static void main(String[] args) throws Exception
  8.         {
  9.                 ServerSocket serverSocket = new ServerSocket(4000);
  10.                
  11.                 while(true)
  12.                 {
  13.                         Socket socket = serverSocket.accept();
  14.                        
  15.                         //启动读写线程
  16.                         new ServerInputThread(socket).start();
  17.                         new ServerOutputThread(socket).start();
  18.                 }
  19.         }
  20. }
复制代码
  1. 服务器端等待客户端传入数据的线程：
  2. import java.io.IOException;
  3. import java.io.InputStream;
  4. import java.net.Socket;

  6. public class ServerInputThread extends Thread
  7. {
  8.         private Socket socket;
  9.        
  10.         public ServerInputThread(Socket socket)
  11.         {
  12.                 this.socket = socket;
  13.         }
  14.        
  15.         @Override
  16.         public void run()
  17.         {
  18.                 try
  19.                 {
  20.                         InputStream is = socket.getInputStream();
  21.                         System.out.println("等待客户端的输出");
  22.                         while(true)
  23.                         {
  24.                                
  25.                                
  26.                                 byte[] buffer = new byte[1024];
  27.                                
  28.                                 int length = is.read(buffer);
  29.                                
  30.                                 String str = new String(buffer, 0, length);
  31.                                
  32.                                 System.out.println(str);
  33.                         }
  34.                 }
  35.                 catch (IOException e)
  36.                 {
  37.                         e.printStackTrace();
  38.                 }
  39.         }
  40. }
复制代码
  1. 服务器端向客户端传递数据的线程：
  2. import java.io.BufferedReader;
  3. import java.io.IOException;
  4. import java.io.InputStreamReader;
  5. import java.io.OutputStream;
  6. import java.net.Socket;

  8. public class ServerOutputThread extends Thread
  9. {
  10.         private Socket socket;

  12.         public ServerOutputThread(Socket socket)
  13.         {
  14.                 this.socket = socket;
  15.         }

  17.         @Override
  18.         public void run()
  19.         {
  20.                 try
  21.                 {
  22.                         OutputStream os = socket.getOutputStream();
  23.             System.out.println("服务器端请输入：");
  24.                         while(true)
  25.                         {
  26.                                
  27.                                 BufferedReader reader = new BufferedReader(new InputStreamReader(
  28.                                                 System.in));
  29.                                
  30.                                 String line = reader.readLine();
  31.                                
  32.                                 os.write(line.getBytes());
  33.                         }
  34.                 }
  35.                 catch (IOException e)
  36.                 {
  37.                         e.printStackTrace();
  38.                 }
  39.         }
  40. }
复制代码
  1. 客户端：
  2. import java.io.*;
  3. import java.net.Socket;

  5. public class MainClient
  6. {
  7.         public static void main(String[] args) throws Exception, IOException
  8.         {
  9.                 Socket socket = new Socket("localhost", 6000);

  11.                 new ClientInputThread(socket).start();
  12.                 new ClientOutputThread(socket).start();

  14.      
  15.         }
  16. }
复制代码
  1. 客户端准备接收服务器端数据的线程：
  2. import java.io.IOException;
  3. import java.io.InputStream;
  4. import java.net.Socket;

  6. public class ClientInputThread extends Thread
  7. {
  8.         private Socket socket;
  9.        
  10.         public ClientInputThread(Socket socket)
  11.         {
  12.                 this.socket = socket;
  13.         }
  14.        
  15.         @Override
  16.         public void run()
  17.         {
  18.                 try
  19.                 {
  20.                         InputStream is = socket.getInputStream();
  21.                         System.out.println("等待服务器端的输出：");
  22.                         while(true)
  23.                         {
  24.                                
  25.                                 byte[] buffer = new byte[1024];
  26.                                
  27.                                 int length = is.read(buffer);
  28.                                
  29.                                 String str = new String(buffer, 0, length);
  30.                                
  31.                                 System.out.println(str);
  32.                         }
  33.                 }
  34.                 catch (IOException e)
  35.                 {
  36.                         e.printStackTrace();
  37.                 }
  38.         }
  39. }
复制代码
  1. 客户端准备向服务器端传递数据的线程：
  2. import java.io.BufferedReader;
  3. import java.io.IOException;
  4. import java.io.InputStreamReader;
  5. import java.io.OutputStream;
  6. import java.net.Socket;

  8. public class ClientOutputThread extends Thread
  9. {
  10.         private Socket socket;

  12.         public ClientOutputThread(Socket socket)
  13.         {
  14.                 this.socket = socket;
  15.         }

  17.         @Override
  18.         public void run()
  19.         {
  20.                 try
  21.                 {
  22.                         OutputStream os = socket.getOutputStream();
  23.             System.out.println("等待客户端输入：");
  24.                         while (true)
  25.                         {
  26.                                
  27.                                 BufferedReader reader = new BufferedReader(
  28.                                                 new InputStreamReader(System.in));

  30.                                 String line = reader.readLine();

  32.                                 os.write(line.getBytes());
  33.                         }
  34.                 }
  35.                 catch (IOException e)
  36.                 {
  37.                         e.printStackTrace();
  38.                 }
  39.         }
  40. }
复制代码
开启服务器后，再开多个客户端的时候，当服务器向客户端发送数据的时候，为什么有的客户端能接收到服务器传递的数据，有的客户端不能接收到？

Socket网络

0 个回复

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 加入黑马