Socket简介:
Socket称为“套接字”,描述IP地址和端口。在Internet上的主机一般运行多个服务软件,同时提供几种服务,每种服务都打开一个Socket,并绑定在一个端口上,不同的端口对应于不同的服务。Socket和ServerSocket类位于java.net包中。ServerSocket用于服务端,Socket是建立网络连接时使用的。连接成功时,应用程序两端都会产生一个Socket实例,通过操作这个实例完成所需会话。
Socket常用方法:
-int getLocalPort() 获取本地使用的端口号
-InetAddress getLocalAddress() 获取套接字绑定的本地地址
-int getPort() 获取远端使用的端口号
-InetAddress.getInetAddress() 获取套接字绑定的远端地址
InetAddress常用方法:
-String getCanonicalHostName() 获取此IP地址的完全限定域名。
-String getHostAddress() 返回IP地址字符串
1 //获取本地地址和端口号:2 public void testSocket() throws Exception{3 Socket socket=new Socket("localhost",8088);4 InetAddress add=socket.getLocalAddress();5 System.out.println(add.getCanonicalHostName());6 System.out.println(add.getHostName());7 System.out.println(add.getLocalPort());8 }
1 //获取远端地址和端口号:2 public static void testSocket() throws Exception{3 Socket socket=new Socket("localhost",8088);4 InetAddress inetAdd=socket.getInetAddress();5 System.out.println(inetAdd.getCanonicalHostName());6 System.out.println(inetAdd.getHostName());7 System.out.println(socket.getLocalPort());8 }
其他方法的使用:
package com.demo.inet;import java.net.InetAddress;import java.net.UnknownHostException;import java.util.Arrays;public class InetAddressDemo { public static void main(String[] args) { // 创建一个字节数组byte 127 ~ -128 byte bt[] = {-64,-88,3,44};//192.168.3.44 try { // 创建InetAddress对象 InetAddress id = InetAddress.getByAddress(bt); System.out.println(id); // 返回原始IP地址 byte[] bs = id.getAddress(); System.out.println(Arrays.toString(bs)); // 返回对象对应IP地址 System.out.println(id.getHostAddress()); // 返回全名计算名称 System.out.println(id.getCanonicalHostName()+"------------------"); // 返回本机计算机名及对应ip地址 System.out.println(InetAddress.getLocalHost()); // 返回host名称对应域名及ip地址 InetAddress[] allByName = InetAddress.getAllByName("www.baidu.com"); System.out.println(Arrays.toString(allByName)); System.out.println(allByName[0].getHostName()); // 域名 System.out.println(allByName[0].getHostAddress()); // ip地址 // 同主机名称获取IP信息 InetAddress addr = InetAddress.getByName("localhost"); System.out.println(addr.getHostAddress()); System.out.println(addr.getCanonicalHostName()); // 返回ip地址 } catch (UnknownHostException e) { e.printStackTrace(); } } }
获取网络输入流和网络输出流
通过Socket获取输入流与输出流,主要使用一下两个方法
-InputStream getInputStream() 用于返回此套接字的输入流
-OutStream getOutputStream() 用于返回此套接字的输出流
public static void testSocket() throws Exception { Socket socket = new Socket("localhost", 8088); OutputStream out = socket.getOutputStream(); OutputStreamWriter osw = new OutputStreamWriter(out, "UTF-8"); PrintWriter pw = new PrintWriter(osw, true); pw.println("输出的内容");//发送内容 InputStream in=socket.getInputStream(); InputStreamReader isr=new InputStreamReader(in, "UTF-8"); BufferedReader br=new BufferedReader(isr); br.readLine();//读取接到的内容 }
注意:当使用完Socket进行通讯完毕后,要关闭Socket以释放系统资源
-void close() 关闭套接字,同时也代表关闭了获取的输入与输出流。
服务端ServerSocket监听
1 //创建ServerSocket并申请服务端口80882 ServerSocket server=new ServerSocket(8088);3 /*方法会产生阻塞,直到某个Socket连接,并返回请求连接的Socket*/4 Socket socket=server.accept();5 ...
客户端Socket连接
1 //参数1:服务端的IP地址,参数2:服务端的服务器端口2 //注意:创建Socket的同时就会发起连接,若连接失败会抛出异常3 Socket socket=new Socket("localhost",8088);4 ....
C-S端通信模型
详细实例演示
Server:
package com.demo.server;import java.io.BufferedOutputStream;import java.io.IOException;import java.net.ServerSocket;import java.net.Socket;public class Server { static int port = 12345; public static void main(String[] args) { // 创建服务端Socket对象 ServerSocket serverSocket = null; while (true) { try { // 创建服务端Socket对象 serverSocket = new ServerSocket(port); System.out.println("等待客户端连接服务器......."); // 阻塞服务器 Socket socket = serverSocket.accept(); System.out.println("客户端连接到服务器......."); // 创建文件输出流 BufferedOutputStream os = new BufferedOutputStream(socket.getOutputStream()); os.write("服务器端: 我收到了客户端连接请求。".getBytes()); os.flush(); os.close(); } catch (Exception e) { e.printStackTrace(); } finally { try { if (serverSocket != null) { serverSocket.close(); } } catch (IOException e) { e.printStackTrace(); } } } } }
Client:
package com.demo.client;import java.io.BufferedInputStream;import java.io.IOException;import java.net.Socket;public class Client { static int port = 12345; static String host = "111.231.93.134"; public static void main(String[] args) { // 创建客户端对象 Socket socket = null; try { // 创建客户端对象 socket = new Socket(host, port); // 获取输入流对象 BufferedInputStream bis = new BufferedInputStream(socket.getInputStream()); // 定义缓冲字节数组 byte[] buffer = new byte[1024]; // 定义接收实际长度 int len = 0; while ((len = bis.read(buffer)) != -1) { String content = new String(buffer, 0, len); System.out.println("客户端接收的内容:"+content); } } catch (Exception e) { e.printStackTrace(); } finally { try { if (socket != null) { socket.close(); } } catch (IOException e) { e.printStackTrace(); } } } }
TCP与UDP的区别
TCP(Transmission Control Protocol,传输控制协议)是基于连接的协议,也就是说,在正式收发数据前,必须和对方建立可靠的连接。聊天工具使用TCP协议
UDP(User Data Protocol,用户数据报协议)是与TCP相对应的协议。它是面向非连接的协议,它不与对方建立连接,而是直接就把数据包发送过去! 游戏多使用UDP协议
UDP程序演示:
Server:
import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress; /* * 服务器端,实现基于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(); } }
Client:
import java.io.IOException;import java.net.DatagramPacket;import java.net.DatagramSocket;import java.net.InetAddress; /* * 客户端 */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(); } }