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

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 ClieMKycint_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");

bwhttp://.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相关内容感兴趣的读者可查看本站专题：《Java Socket编程技巧总结》、《Java文件与目录操作技巧汇总》、《Java数据结构与算法教程》、《Java操作DOM节点技巧总结》和《Java缓存操作技巧汇总》

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

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。