Java Socket 通信
2015-11-23 10:47
387 查看
1
/*******************************************************************************
* Copyright (c) 2015, 2015 Hirain Technologies Corporation.
******************************************************************************/
package wwwq;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static final int PORT = 1126;// 监听的端口号(0~1023的端口号为系统所保留)
public static void main(final String[] args) {
System.out.println("服务器启动...\n");
final Server server = new Server();
server.init();
}
public void init() {
try {
final ServerSocket serverSocket = new ServerSocket(PORT);
while (true) {
// 一旦有堵塞, 则表示服务器与客户端获得了连接
final Socket client = serverSocket.accept();
// 处理这次连接
new HandlerThread(client);
}
} catch (final Exception e) {
System.out.println("服务器异常: " + e.getMessage());
}
}
private class HandlerThread implements Runnable {
private Socket socket;
public HandlerThread(final Socket client) {
socket = client;
new Thread(this).start();
}
@Override
public void run() {
try {
// 读取客户端数据
final DataInputStream input = new DataInputStream(socket.getInputStream());
final String clientInputStr = input.readUTF();// 这里要注意和客户端输出流的写方法对应,否则会抛 EOFException
// 处理客户端数据
System.out.println("客户端发过来的内容:" + clientInputStr);
// 向客户端回复信息
final DataOutputStream out = new DataOutputStream(socket.getOutputStream());
System.out.print("(服务器)请输入:\t");
// 发送键盘输入的一行
final String s = new BufferedReader(new InputStreamReader(System.in)).readLine();
out.writeUTF(s);
out.close();
input.close();
} catch (final Exception e) {
System.out.println("服务器 run 异常: " + e.getMessage());
} finally {
if (socket != null) {
try {
socket.close();
} catch (final Exception e) {
socket = null;
System.out.println("服务端 finally 异常:" + e.getMessage());
}
}
}
}
}
}
2
/*******************************************************************************
* Copyright (c) 2015, 2015 Hirain Technologies Corporation.
******************************************************************************/
package wwwq;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class Client {
public static final String IP_ADDR = "localhost";// 服务器地址
public static final int PORT = Server.PORT;// 监听的端口号(0~1023的端口号为系统所保留)
public static void main(final String[] args) {
System.out.println("客户端启动...");
System.out.println("当接收到服务器端字符为 \"OK\" 的时候, 客户端将终止\n");
while (true) {
Socket socket = null;
try {
// 创建一个流套接字并将其连接到指定主机上的指定端口号
socket = new Socket(IP_ADDR, PORT);
// 读取服务器端数据
final DataInputStream input = new DataInputStream(socket.getInputStream());
// 向服务器端发送数据
final DataOutputStream out = new DataOutputStream(socket.getOutputStream());
System.out.print("(客户端)请输入: \t");
final String str = new BufferedReader(new InputStreamReader(System.in)).readLine();
out.writeUTF(str);
final String ret = input.readUTF();
System.out.println("服务器端返回过来的是: " + ret);
// 如接收到 "OK" 则断开连接
if ("OK".equals(ret)) {
System.out.println("客户端将关闭连接");
Thread.sleep(500);
break;
}
out.close();
input.close();
} catch (final Exception e) {
System.out.println("客户端异常:" + e.getMessage());
} finally {
if (socket != null) {
try {
socket.close();
} catch (final IOException e) {
socket = null;
System.out.println("客户端 finally 异常:" + e.getMessage());
}
}
}
}
}
}
3
/*******************************************************************************
* Copyright (c) 2015, 2015 Hirain Technologies Corporation.
******************************************************************************/
package wwwq;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStreamReader;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static final int PORT = 1126;// 监听的端口号(0~1023的端口号为系统所保留)
public static void main(final String[] args) {
System.out.println("服务器启动...\n");
final Server server = new Server();
server.init();
}
public void init() {
try {
final ServerSocket serverSocket = new ServerSocket(PORT);
while (true) {
// 一旦有堵塞, 则表示服务器与客户端获得了连接
final Socket client = serverSocket.accept();
// 处理这次连接
new HandlerThread(client);
}
} catch (final Exception e) {
System.out.println("服务器异常: " + e.getMessage());
}
}
private class HandlerThread implements Runnable {
private Socket socket;
public HandlerThread(final Socket client) {
socket = client;
new Thread(this).start();
}
@Override
public void run() {
try {
// 读取客户端数据
final DataInputStream input = new DataInputStream(socket.getInputStream());
final String clientInputStr = input.readUTF();// 这里要注意和客户端输出流的写方法对应,否则会抛 EOFException
// 处理客户端数据
System.out.println("客户端发过来的内容:" + clientInputStr);
// 向客户端回复信息
final DataOutputStream out = new DataOutputStream(socket.getOutputStream());
System.out.print("(服务器)请输入:\t");
// 发送键盘输入的一行
final String s = new BufferedReader(new InputStreamReader(System.in)).readLine();
out.writeUTF(s);
out.close();
input.close();
} catch (final Exception e) {
System.out.println("服务器 run 异常: " + e.getMessage());
} finally {
if (socket != null) {
try {
socket.close();
} catch (final Exception e) {
socket = null;
System.out.println("服务端 finally 异常:" + e.getMessage());
}
}
}
}
}
}
2
/*******************************************************************************
* Copyright (c) 2015, 2015 Hirain Technologies Corporation.
******************************************************************************/
package wwwq;
import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.Socket;
public class Client {
public static final String IP_ADDR = "localhost";// 服务器地址
public static final int PORT = Server.PORT;// 监听的端口号(0~1023的端口号为系统所保留)
public static void main(final String[] args) {
System.out.println("客户端启动...");
System.out.println("当接收到服务器端字符为 \"OK\" 的时候, 客户端将终止\n");
while (true) {
Socket socket = null;
try {
// 创建一个流套接字并将其连接到指定主机上的指定端口号
socket = new Socket(IP_ADDR, PORT);
// 读取服务器端数据
final DataInputStream input = new DataInputStream(socket.getInputStream());
// 向服务器端发送数据
final DataOutputStream out = new DataOutputStream(socket.getOutputStream());
System.out.print("(客户端)请输入: \t");
final String str = new BufferedReader(new InputStreamReader(System.in)).readLine();
out.writeUTF(str);
final String ret = input.readUTF();
System.out.println("服务器端返回过来的是: " + ret);
// 如接收到 "OK" 则断开连接
if ("OK".equals(ret)) {
System.out.println("客户端将关闭连接");
Thread.sleep(500);
break;
}
out.close();
input.close();
} catch (final Exception e) {
System.out.println("客户端异常:" + e.getMessage());
} finally {
if (socket != null) {
try {
socket.close();
} catch (final IOException e) {
socket = null;
System.out.println("客户端 finally 异常:" + e.getMessage());
}
}
}
}
}
}
3
相关文章推荐
- java-模拟tomcat服务器
- Linux socket 初步
- java socket 注意的地方
- java socket 注意的地方
- C#基于socket模拟http请求的方法
- 简单的Ruby中的Socket编程教程
- Socket不能选择本地IP连接问题如何解决
- C#之Socket操作类实例解析
- 使用C#来编写一个异步的Socket服务器
- C#使用Socket快速判断数据库连接是否正常的方法
- 科学知识:理解socket
- php与flash as3 socket通信传送文件实现代码
- 解决time_wait强制关闭socket
- C#使用Socket上传并保存图片的方法
- 深入php socket的讲解与实例分析
- Linux网络编程之UDP Socket程序示例
- Linux网络编程之socket文件传输示例
- filezilla Failed to create listen socket on port 21 for IPv4 解决办法
- php socket方式提交的post详解
- PHP异步调用socket实现代码