python socket双向通信_Java --socket双向通信

如下例子实现了利用socket简易双向通信的例子

1.建立两个java project，目录如下

2.客户端代码

package client;

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.Socket;

public class Client {

public static void main(String args[])

{

try{

//创建客户端套接字

Socket socket = new Socket("127.0.0.1", 9999);

//获取套接字输入流

InputStream is = socket.getInputStream();

DataInputStream dis = new DataInputStream(is);

//获取套接字输出流

OutputStream os = socket.getOutputStream();

DataOutputStream dos = new DataOutputStream(os);

//从键盘输入

InputStreamReader isr = new InputStreamReader(System.in);

BufferedReader br = new BufferedReader(isr);

//聊天

String message;

while (true) {

//读取键盘输入的字符，写到客户端输出流

message = br.readLine();

dos.writeUTF(message);

if(message.equals("88"))

break;

//读取服务器端的数据并打印到屏幕上

message = dis.readUTF();

System.out.println("服务器传回的消息:"+message);

}

//关闭流

dis.close();

dos.close();

socket.close();

}catch(Exception e)

{

e.printStackTrace();

}

}

}

3.服务器端代码

package server;

import java.io.BufferedReader;

import java.io.DataInputStream;

import java.io.DataOutputStream;

import java.io.InputStream;

import java.io.InputStreamReader;

import java.io.OutputStream;

import java.net.ServerSocket;

import java.net.Socket;

public class Server {

public static void main(String args[])

{

try {

//创建一个ServerSocket,在端口号9999上监听客户端请求

ServerSocket serverSocket = new ServerSocket(9999);

Socket socket = serverSocket.accept();

//获取客户端套接字的输出流

OutputStream os = socket.getOutputStream();

DataOutputStream dos = new DataOutputStream(os);

//获取客户端输入流

InputStream is = socket.getInputStream();

DataInputStream dis = new DataInputStream(is);

//创建字符输入流接受键盘输入

InputStreamReader isr= new InputStreamReader(System.in);

BufferedReader br= new BufferedReader(isr);

//消息

String message;

while (true) {

//获取客户端输入流

message = dis.readUTF();

System.out.println("客户端发过来消息:"+message);

if(message.equals("88"))

break;

//读取键盘输入并写入到输出流

message = br.readLine();

dos.writeUTF(message);

}

dis.close();

dos.close();

serverSocket.close();

socket.close();

} catch (Exception e) {

// TODO: handle exception

e.printStackTrace();

}

}

}

4.调试

1>服务器端项目 Run as-->Java Application，可以打个log看下启动成功。

2>客户端项目 Run as-->Java Application，可以打个log看下启动成功。客户端运行起来后会覆盖服务端的log。

3>先将控制权调到客户端这边，即用鼠标点击客户端main方法，在控制台(console)里面输入客户端需要发送的消息，回车键即可发送。

此时控制台会输出消息客户端发过来消息：xxxxxxx(这是你自己输入的消息)

4>将控制权调到服务器这边，即用鼠标点击服务器端main方法，在控制台(console)里面输入服务器端需要发送的消息，回车键即可发送。

如下是调试截图

4.1 客户端输入，还未回车

4.2 客户端点击了回车键，服务器端收到的消息

4.3 接着，服务器端回消息

4.4 客户端再发消息

至此，完成了简单的即时通讯。