java网络编程二:服务器处理多个用户请求的解决方案(返回多个用户输入的信息)
2016-03-04 10:27
886 查看
1、用多个线程来同时为多个客户提供服务,这是提高服务器的并发性能的最常用的手段,那么怎样来为多个用户提供服务呢?
主要有三种方法:
2、为了更清楚理解服务器到底是怎么工作的,下面用第一种方式来处理多个用户请求。如果想用第二、第三方式可以参考Touch的博客:
java多线程总结五:线程池的原理及实现
下面的示例中客户端输入信息,服务器端回复相同的信息,可以同时开启多个客户端,同时输入信息,源代码如下:
服务器端代码:
[java]
view plain
copy
<span style="font-size:16px;">package demo.net;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服务器返回用户输入的信息, 为多个用户提供服务:为每个客户分配一个工作线程
*/
public class ChatServers {
private int port = 8189;// 默认服务器端口
public ChatServers() {
}
// 创建指定端口的服务器
public ChatServers(int port) {
this.port = port;
}
public void service() {
int i=0;
try {
// 建立服务器连接,设定客户连接请求队列的长度
ServerSocket server = new ServerSocket(port,3);
while (true) {
// 等待客户连接
Socket socket = server.accept();
i++;
System.out.println("第"+i+"个客户连接成功!");
new Thread(new ServerThread(socket)).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new ChatServers().service();
}
}
class ServerThread implements Runnable {
private Socket socket;
public ServerThread(Socket socket) {
this.socket = socket;
}
// 任务是为一个用户提供服务
@Override
public void run() {
try {
try {
// 读取客户端传过来信息的DataInputStream
DataInputStream in = new DataInputStream(socket
.getInputStream());
// 向客户端发送信息的DataOutputStream
DataOutputStream out = new DataOutputStream(socket
.getOutputStream());
while (true) {
// 读取来自客户端的信息
String accpet = in.readUTF();
out.writeUTF("服务器:" + accpet);
}
} finally {// 建立连接失败的话不会执行socket.close();
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
</span>
客户端代码:
[java]
view plain
copy
<span style="font-size:16px;">package demo.net;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
/**
* 注意用到的输入输出流DataInputStream和DataOutputStream,成对出现,最好用字节流
*/
// 客户端类
public class ChatClients {
private String host = "localhost";// 默认连接到本机
private int port = 8189;// 默认连接到端口8189
public ChatClients() {
}
// 连接到指定的主机和端口
public ChatClients(String host, int port) {
this.host = host;
this.port = port;
}
public void chat() {
try {
// 连接到服务器
Socket socket = new Socket(host, port);
try {
// 读取服务器端传过来信息的DataInputStream
DataInputStream in = new DataInputStream(socket
.getInputStream());
// 向服务器端发送信息的DataOutputStream
DataOutputStream out = new DataOutputStream(socket
.getOutputStream());
// 装饰标准输入流,用于从控制台输入
Scanner scanner = new Scanner(System.in);
while (true) {
String send = scanner.nextLine();
// 把从控制台得到的信息传送给服务器
out.writeUTF(send);
// 读取来自服务器的信息
String accpet = in.readUTF();
System.out.println(accpet);
}
} finally {
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new ChatClients().chat();
}
}
</span>
运行结果:
主要有三种方法:
2、为了更清楚理解服务器到底是怎么工作的,下面用第一种方式来处理多个用户请求。如果想用第二、第三方式可以参考Touch的博客:
java多线程总结五:线程池的原理及实现
下面的示例中客户端输入信息,服务器端回复相同的信息,可以同时开启多个客户端,同时输入信息,源代码如下:
服务器端代码:
[java]
view plain
copy
<span style="font-size:16px;">package demo.net;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
/**
* 服务器返回用户输入的信息, 为多个用户提供服务:为每个客户分配一个工作线程
*/
public class ChatServers {
private int port = 8189;// 默认服务器端口
public ChatServers() {
}
// 创建指定端口的服务器
public ChatServers(int port) {
this.port = port;
}
public void service() {
int i=0;
try {
// 建立服务器连接,设定客户连接请求队列的长度
ServerSocket server = new ServerSocket(port,3);
while (true) {
// 等待客户连接
Socket socket = server.accept();
i++;
System.out.println("第"+i+"个客户连接成功!");
new Thread(new ServerThread(socket)).start();
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new ChatServers().service();
}
}
class ServerThread implements Runnable {
private Socket socket;
public ServerThread(Socket socket) {
this.socket = socket;
}
// 任务是为一个用户提供服务
@Override
public void run() {
try {
try {
// 读取客户端传过来信息的DataInputStream
DataInputStream in = new DataInputStream(socket
.getInputStream());
// 向客户端发送信息的DataOutputStream
DataOutputStream out = new DataOutputStream(socket
.getOutputStream());
while (true) {
// 读取来自客户端的信息
String accpet = in.readUTF();
out.writeUTF("服务器:" + accpet);
}
} finally {// 建立连接失败的话不会执行socket.close();
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
</span>
客户端代码:
[java]
view plain
copy
<span style="font-size:16px;">package demo.net;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.Scanner;
/**
* 注意用到的输入输出流DataInputStream和DataOutputStream,成对出现,最好用字节流
*/
// 客户端类
public class ChatClients {
private String host = "localhost";// 默认连接到本机
private int port = 8189;// 默认连接到端口8189
public ChatClients() {
}
// 连接到指定的主机和端口
public ChatClients(String host, int port) {
this.host = host;
this.port = port;
}
public void chat() {
try {
// 连接到服务器
Socket socket = new Socket(host, port);
try {
// 读取服务器端传过来信息的DataInputStream
DataInputStream in = new DataInputStream(socket
.getInputStream());
// 向服务器端发送信息的DataOutputStream
DataOutputStream out = new DataOutputStream(socket
.getOutputStream());
// 装饰标准输入流,用于从控制台输入
Scanner scanner = new Scanner(System.in);
while (true) {
String send = scanner.nextLine();
// 把从控制台得到的信息传送给服务器
out.writeUTF(send);
// 读取来自服务器的信息
String accpet = in.readUTF();
System.out.println(accpet);
}
} finally {
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
new ChatClients().chat();
}
}
</span>
运行结果:
相关文章推荐
- c# httpgethtml
- http状态码大全(HTTP Status Code) Curl http_code 状态码 意义
- 解决httpclient访问ssl资源报证书错误的问题
- xutils 3的简单使用
- 轻量级HTTP服务器Nginx(常用配置…
- WEB服务器TCP:time wait&nbsp…
- web性能测试工具-http_load
- HTTP协议详解(真的很经典)
- 网络安全运维
- iOS实际网络检测框架RealReachability
- uploadify3.1--3.2 HTTP&nbsp…
- http请求中application/x-www-form…
- 【HTTP】http重定向301/302/303/307
- 常见HTTP状态码
- Web服务器性能/压力测试工具http_l…
- PHP的$_SERVER['HTTP_H…
- PHP实现http与https转化
- NSCache和NSURLCache网络缓存优化
- 高效的使用okhttp
- BASIC HTTP AUTHENTICATION ON ANDROID