java语言 百分网手机站

Javasocket应用实例

时间:2020-11-10 10:47:46 java语言 我要投稿

Javasocket应用实例

  引导语:运用Java,我们可以编出很多有趣的小程序,以下是百分网小编分享给大家的Javasocket应用实例,希望大家喜欢!

  用于本机上的客户端与服务器对话的'小程序:

  客户端:

  import java.io.BufferedReader;

  import java.io.BufferedWriter;

  import java.io.InputStreamReader;

  import java.io.OutputStreamWriter;

  import java.net.Socket;

  public class Client extends Thread

  {

  public void Write() throws Exception

  {

  Socket s=new Socket("127.0.0.1",12345);

  BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));

  BufferedReader br=new BufferedReader(new InputStreamReader(System.in));

  String message="客户端说:";

  while(!(message.equals("")))

  {

  message=br.readLine();

  System.out.println("客户端说:"+message);

  bw.write(message+"\n");

  bw.flush();

  }

  bw.close();

  s.close();

  }

  public void run()

  {

  Socket m=null;

  BufferedReader dr=null;

  try

  {

  m=new Socket("127.0.0.1",12345);

  dr=new BufferedReader(new InputStreamReader(m.getInputStream()));

  String msg="服务器说:";

  while(!(msg.equals("")))

  {

  msg=dr.readLine();

  System.out.println("服务器说:"+msg);

  }

  }

  catch(Exception e){e.printStackTrace();}

  finally

  {

  try

  {

  dr.close();

  m.close();

  }

  catch(Exception e){e.printStackTrace();}

  }

  }

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

  {

  Client c=new Client();

  c.start();

  c.Write();

  }

  }

  服务器:

  import java.io.BufferedReader;

  import java.io.BufferedWriter;

  import java.io.InputStreamReader;

  import java.io.OutputStreamWriter;

  import java.net.ServerSocket;

  import java.net.Socket;

  public class Server extends Thread

  {

  private ServerSocket ss=null;

  public Server ()throws Exception

  {

  ss=new ServerSocket(12345);

  }

  public void Write()throws Exception

  {

  Socket s=ss.accept();

  BufferedWriter bw=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));

  BufferedReader br=new BufferedReader(new InputStreamReader(System.in));

  String message="服务器说:";

  while(!(message.equals("")))

  {

  message=br.readLine();

  System.out.println("服务器说:"+message);

  bw.write(message+"\n");

  bw.flush();

  }

  //bw.close();

  s.close();

  }

  public void run()

  {

  Socket m=null;

  BufferedReader dr=null;

  try

  {

  m=ss.accept();

  dr=new BufferedReader(new InputStreamReader(m.getInputStream()));

  String msg="客户端说:";

  while(!(msg.equals("")))

  {

  msg=dr.readLine();

  System.out.println("客户端:"+msg);

  }

  }

  catch(Exception e){e.printStackTrace();}

  finally

  {

  try

  {

  dr.close();

  m.close();

  }

  catch(Exception e){e.printStackTrace();}

  }

  }

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

  {

  Server s=new Server();

  s.start();

  s.Write();

  }

  }