首页 > 程序开发 > 软件开发 > Java >

JavaSE入门教程之Socket网络通信编程

2017-11-03

JavaSE入门教程之Socket网络通信编程。

JavaSE入门教程之Socket网络通信编程

(4)使用多线程实现多客户端的通信

多线程服务器实现

应用多线程来实现服务器与客户端之间的通信基本步骤:。

1)服务器端创建ServerSocket,循环调用accept()方法等到客户端连接。

2)客户端创建一个socket并请求和服务器端连接。

3)服务器端接受客户端请求,创建socket与该客户建立专线连接。

4)建立连接的两个socket在一个单独的线程上对话。

5)服务器端继续等待新的连接。

实例代码:

ServerThread.java源文件代码:

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();
			}
		}
	}                                     

改写的Server.java源文件代码:

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();
		}
	}
}

改写的Client.java源文件代码:

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();
		}
	}
}

运行结果:

启动一个客户端的结果:

客户端结果:

\

服务器端结果:

\

启动两个客户端的结果:

客户端结果:同第一个结果。

服务器端结果:

\

启动三个客户端的结果:
客户端结果:同第一个结果。

服务器端结果:

\

五通过Socket实现UDP编程

(1)UDP编程

UDP协议(用户数据报协议)是无连接、不可靠、无序的。UDP协议以数据报作为数据传输的载体。进行数据传输

时,首先需要将要传输的数据定义成数据报(Datagram),在数据报中指明数据所要到达的Socket(主机地址和端口

号),然后再将数据报发送出去。

(2)相关操作类

1)DatagramPacket类

DatagramPacket类:表示数据报包。

DatagramPacket类的构造方法:

\

DatagramPacket类的方法:

\

2)DatagramSocket类

DatagramSocket类:进行端到端通信的类。此类表示用来发送和接收数据报包的套接字。

DatagramSocket类的构造方法:

\

DatagramSocket类的方法:

\

\

\

(3)编程实现基于UDP的Socket通信之服务器端

服务器端实现步骤

1)创建DatagramSocket,指定端口号。

2)创建DatagramPacket。

3)接收客户端发送的数据信息。

4)读取数据。

客户端实现步骤

1)定义发送信息。

2)创建DatagramPacket,包含将要发送的信息。

3)创建DatagramSocket。

4)发送数据。

(4)实例

一对一(一个服务器和一个客户端)UDP编程实例代码:

UDPServer.java源文件代码:

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();
	}
}

UDPClient.java源文件代码:

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();
	}
}

运行结果:

服务器端;

\

客户端:

\

(5)基于UDP实现多用户登录

这个可以和基于TCP实现多用户登录相对比,然后修改一下TCP编程的内容就可以实现UDP多用户登录。


相关文章
最新文章
热点推荐