java 网络编程多个客户端连接服务器

女爷i 2022-08-17 14:22 310阅读 0赞

import java.io.BufferedReader;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.net.ServerSocket;  
import java.net.Socket;  
  
  
public class ServerDemo implements Runnable  
\{   
ServerSocket server = null;   //创建ServerSocket对象；  
Socket socket = null; //创建Socket对象；  
BufferedReader br = null; //创建BufferedReader对象；  
String content; //存放客户端读取的内容；  
public static void main(String\[\] args)   
\{   
ServerDemo serverDemo = new ServerDemo();  
try   
\{  
serverDemo.server = new ServerSocket(10086);  
\} catch (IOException e)   
\{  
e.printStackTrace();  
\}  
Thread t1 = new Thread(serverDemo);     //两个客户端，开启两个子线程；  
Thread t2 = new Thread(serverDemo);  
t1.start();  
t2.start();  
\}  
public void run()   
\{  
while(true)  
\{  
try   
\{   
socket = server.accept();        //实例化socket对象，若连接，则创建一套数字；  
br = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
System.out.println("客户端连接成功");  
socket.shutdownOutput();   
while((content = br.readLine()) != null)  
\{   
System.out.println(content);  
\}  
socket.shutdownInput();   
\} catch (IOException e)   
\{  
e.printStackTrace();  
\}finally  
\{  
try   
\{  
br.close();  
server.close();  
\} catch (IOException e)   
\{  
e.printStackTrace();  
\}  
  
\}  
\}   
\}

import java.io.BufferedReader;  
import java.io.BufferedWriter;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.io.OutputStreamWriter;  
import java.net.Socket;  
import java.net.UnknownHostException;  
  
  
public class ClientDemo1   
\{  
public static void main(String\[\] args)   
\{  
startClient();  
\}  
private static void startClient()  
\{  
BufferedReader br = null;  
BufferedWriter bw = null;  
try   
\{  
Socket socket = new Socket("localhost", 10086);  
br = new BufferedReader(new InputStreamReader(System.in));  
bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  
System.out.println("client1连接服务器连接成功");  
String content;  
while(!(content = br.readLine()).equals("886"))  
\{  
bw.write(content + "\\n");  
bw.flush();  
\}  
\} catch (UnknownHostException e)   
\{  
e.printStackTrace();  
\} catch (IOException e)   
\{  
e.printStackTrace();  
\}  
try \{  
br.close();  
bw.close();  
\} catch (IOException e)    
\{  
e.printStackTrace();  
\}  
\}  
\}

import java.io.BufferedReader;  
import java.io.BufferedWriter;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.io.OutputStreamWriter;  
import java.net.Socket;  
import java.net.UnknownHostException;  
  
public class ClientDemo2   
\{  
public static void main(String\[\] args)   
\{  
startClient();  
\}  
private static void startClient()  
\{  
BufferedReader br = null;  
BufferedWriter bw = null;  
try   
\{  
Socket socket = new Socket("localhost", 10086);  
br = new BufferedReader(new InputStreamReader(System.in));  
bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));  
System.out.println("client1连接服务器连接成功");  
String content;  
while(!(content = br.readLine()).equals("886"))  
\{  
bw.write(content + "\\n");  
bw.flush();  
\}  
\} catch (UnknownHostException e)   
\{  
e.printStackTrace();  
\} catch (IOException e)   
\{  
e.printStackTrace();  
\}  
try \{  
br.close();  
bw.close();  
\} catch (IOException e)    
\{  
e.printStackTrace();  
\}  
\}  
\}