标签：
多线程服务器实现
应用多线程来实现服务器与客户端之间的通信基本步骤：。
1)服务器端创建ServerSocket，循环调用accept()方法等到客户端连接。
2)客户端创建一个socket并请求和服务器端连接。
3)服务器端接受客户端请求，创建socket与该客户建立专线连接。
4)建立连接的两个socket在一个单独的线程上对话。
5)服务器端继续等待新的连接。
实例代码：
ServerThread.java源文件代码：
<span style="font-size:18px;">import java.io.*;
import java.net.*;
/*
* 服务器线程处理类
*/
public class ServerThread extends Thread {
// 和本线程相关的Socket
Socket socket = null;
public ServerThread(Socket socket) {
this.socket = socket;
}
//线程执行的操作，响应客户端的请求
public void run(){
InputStream is=null;
InputStreamReader isr=null;
BufferedReader br=null;
OutputStream os=null;
PrintWriter pw=null;
try {
//获取输入流，并读取客户端信息
is = socket.getInputStream();
isr = new InputStreamReader(is);
br = new BufferedReader(isr);
String info=null;
//循环读取客户端的信息
while((info=br.readLine())!=null){
System.out.println("我是服务器，客户端说："+info);
}
socket.shutdownInput();//关闭输入流
//获取输出流，响应客户端的请求
os = socket.getOutputStream();
pw = new PrintWriter(os);
pw.write("欢迎您！");
//调用flush()方法将缓冲输出
pw.flush();
} catch (IOException e)
e.printStackTrace();
}finally{
//关闭资源
try {
if(pw!=null)
pw.close();
if(os!=null)
os.close();
if(br!=null)
br.close();
if(isr!=null)
isr.close();
if(is!=null)
is.close();
if(socket!=null)
socket.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}<span style="font-family: Arial, Helvetica, sans-serif; background-color: rgb(255, 255, 255);"> </span></span>
改写的Server.java源文件代码：
<span style="font-size:18px;">import java.net.*;
import java.io.*;
/*
*基于TCP协议的Socket通信，实现用户登录
*服务器端
*/
public class Server{
public static void main(String[] args){
try {
//1.创建一个服务器端Socket，即ServerSocket，指定绑定的端口，并监听此端口
ServerSocket serverSocket=new ServerSocket(8111);
Socket socket=null;
//记录客户端的数量
int count=0;
System.out.println("***服务器即将启动，等待客户端的连接***");
//循环监听等待客户端的连接
while(true){
//调用accept()方法开始监听，等待客户端的连接
socket=serverSocket.accept();
//创建一个新的线程
ServerThread serverThread=new ServerThread(socket);
//启动线程
serverThread.start();
count++;//统计客户端的数量
System.out.println("客户端的数量："+count);
InetAddress address=socket.getInetAddress();
System.out.println("当前客户端的IP："+address.getHostAddress());
}
} catch (IOException e) {
e.printStackTrace();
}
}
}</span>
改写的Client.java源文件代码：
<span style="font-size:18px;">import java.net.*;
import java.io.*;
/*
*基于TCP协议的Socket通信，实现用户登录
*客户端
*/
public class Client{
public static void main(String[] args){
try {
//1.创建客户端Socket，指定服务器地址和端口
Socket socket=new Socket("localhost", 8111);
//2.获取输出流，向服务器端发送信息
OutputStream os=socket.getOutputStream();//字节输出流
PrintWriter pw=new PrintWriter(os);//将输出流包装为打印流
pw.write("用户名：admin;密码：789");
pw.flush();
socket.shutdownOutput();//关闭输出流
//3.获取输入流，并读取服务器端的响应信息
InputStream is=socket.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String info=null;
while((info=br.readLine())!=null){
System.out.println("我是客户端，服务器说："+info);
}
//4.关闭资源
br.close();
is.close();
pw.close();
os.close();
socket.close();
} catch (UnknownHostException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
}</span>
运行结果：启动一个客户端的结果：
客户端结果：
服务器端结果：
启动两个客户端的结果：
客户端结果：同第一个结果。服务器端结果：
服务器端结果：
UDP协议(用户数据报协议)是无连接、不可靠、无序的。UDP协议以数据报作为数据传输的载体。进行数据传输
时，首先需要将要传输的数据定义成数据报(Datagram)，在数据报中指明数据所要到达的Socket(主机地址和端口
号)，然后再将数据报发送出去。
DatagramPacket类：表示数据报包。
DatagramPacket类的构造方法：
DatagramPacket类的方法：
DatagramSocket类：进行端到端通信的类。此类表示用来发送和接收数据报包的套接字。
DatagramSocket类的构造方法：
DatagramSocket类的方法：
1)创建DatagramSocket，指定端口号。
2)创建DatagramPacket。
3)接收客户端发送的数据信息。
4)读取数据。
1)定义发送信息。
2)创建DatagramPacket，包含将要发送的信息。3)创建DatagramSocket。
4)发送数据。
一对一(一个服务器和一个客户端)UDP编程实例代码：
UDPServer.java源文件代码：
<span style="font-size:18px;">import java.io.*;
import java.net.*;
/*
* 服务器端，实现基于UDP的用户登陆
*/
public class UDPServer {
public static void main(String[] args) throws IOException {
/*
* 接收客户端发送的数据
*/
//1.创建服务器端DatagramSocket，指定端口
DatagramSocket socket=new DatagramSocket(8800);
//2.创建数据报，用于接收客户端发送的数据
byte[] data =new byte[1024];//创建字节数组，指定接收的数据包的大小
DatagramPacket packet=new DatagramPacket(data, data.length);
//3.接收客户端发送的数据
System.out.println("****服务器端已经启动，等待客户端发送数据");
socket.receive(packet);//此方法在接收到数据报之前会一直阻塞
//4.读取数据
String info=new String(data, 0, packet.getLength());
System.out.println("我是服务器，客户端说："+info);
/*
* 向客户端响应数据
*/
//1.定义客户端的地址、端口号、数据
InetAddress address=packet.getAddress();
int port=packet.getPort();
byte[] data2="欢迎您!".getBytes();
//2.创建数据报，包含响应的数据信息
DatagramPacket packet2=new DatagramPacket(data2, data2.length, address, port);
//3.响应客户端
socket.send(packet2);
//4.关闭资源
socket.close();
}
}</span>
UDPClient.java源文件代码：
<span style="font-size:18px;">import java.io.*;
import java.net.*;
/*
* 客户端
*/
public class UDPClient {
public static void main(String[] args) throws IOException {
/*
* 向服务器端发送数据
*/
//1.定义服务器的地址、端口号、数据
InetAddress address=InetAddress.getByName("localhost");
int port=8800;
byte[] data="用户名：admin;密码：123".getBytes();
//2.创建数据报，包含发送的数据信息
DatagramPacket packet=new DatagramPacket(data, data.length, address, port);
//3.创建DatagramSocket对象
DatagramSocket socket=new DatagramSocket();
//4.向服务器端发送数据报
socket.send(packet);
/*
* 接收服务器端响应的数据
*/
//1.创建数据报，用于接收服务器端响应的数据
byte[] data2=new byte[1024];
DatagramPacket packet2=new DatagramPacket(data2, data2.length);
//2.接收服务器响应的数据
socket.receive(packet2);
//3.读取数据
String reply=new String(data2, 0, packet2.getLength());
System.out.println("我是客户端，服务器说："+reply);
//4.关闭资源
socket.close();
}
}</span>
运行结果：
服务器端;
客户端：
这个可以和基于TCP实现多用户登录相对比，然后修改一下TCP编程的内容就可以实现UDP多用户登录。
标签：
原文地址：http://blog.csdn.net/erlian1992/article/details/51604645
