亲宝软件园·资讯

展开

Java Socket双向通信 Java开发实现的Socket双向通信功能示例

看看白云 人气:0
想了解Java开发实现的Socket双向通信功能示例的相关内容吗,看看白云在本文为您仔细讲解Java Socket双向通信的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:Java,Socket,双向通信,下面大家一起来学习吧。

本文实例讲述了Java开发实现的Socket双向通信功能。分享给大家供大家参考,具体如下:

服务端

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Server_1 {
  public static void main(String[] args) {
    InputStreamReader isr;
    BufferedReader br;
    OutputStreamWriter osw;
    BufferedWriter bw;
    String str;
    Scanner in = new Scanner(System.in);
    try {
      ServerSocket server = new ServerSocket(4444);// 在本机的4444端口开放Server
      Socket socket = server.accept();// 只要产生连接,socket便可以代表所连接的那个物体,同时这个server.accept()只有产生了连接才会进行下一步操作。
      System.out.println(socket.getInetAddress());// 输出连接者的IP。
      System.out.println("建立了一个连接!");
      while (true) {
        isr = new InputStreamReader(socket.getInputStream());
        br = new BufferedReader(isr);
        System.out.println(socket.getInetAddress() + ":" + br.readLine());
        osw = new OutputStreamWriter(socket.getOutputStream());
        bw = new BufferedWriter(osw);
        System.out.print("回复:");
        str = in.nextLine();
        bw.write(str + "\n");
        bw.flush();
      }
    } catch (IOException e) {
      // TODO Auto-generated catch block
      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.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
public class Client_1 {
  public static void main(String[] args) {
    InputStreamReader isr;
    BufferedReader br;
    OutputStreamWriter osw;
    BufferedWriter bw;
    String str;
    Scanner in = new Scanner(System.in);
    try {
      Socket socket = new Socket("localhost", 4444);
//     System.out.println(socket.getInetAddress());// 输出连接者的IP。
      System.out.println("成功连接服务器");
      while (true) {
        osw = new OutputStreamWriter(socket.getOutputStream());
        bw = new BufferedWriter(osw);
        System.out.print("回复:");
        str = in.nextLine();
        bw.write(str + "\n");
        bw.flush();
        isr = new InputStreamReader(socket.getInputStream());
        br = new BufferedReader(isr);
        System.out.println(socket.getInetAddress() + ":" + br.readLine());
      }
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.printStackTrace();
    }
  }
}

希望本文所述对大家java程序设计有所帮助。

加载全部内容

相关教程
猜你喜欢
用户评论