java网络编程Socket

2019-11-08 19:54:29

字体：大中小

来源：转载

供稿：网友

概述

用java语言实现计算机间数据的信息传递和资源共享

三要素

1. ip地址 2. 端口应用程序的标识。范围：0-65535。其中0-1024不建议使用。 3. 协议 UDP:数据打包,有限制,不连接,效率高,不可靠 TCP:建立数据通道,无限制,效率低,可靠

IP地址

网络中计算机的唯一标识

组成：网络号段+主机号段

A类：第一号段为网络号段+后三段的主机号段一个网络号：256*256*256 = 16777216B类：前二号段为网络号段+后二段的主机号段一个网络号：256*256 = 65536C类：前三号段为网络号段+后一段的主机号段一个网络号：256

分类：

A类 1.0.0.1---127.255.255.254 1) 10.X.X.X是私有地址(私有地址就是在互联网上不使用，而被用在局域网络中的地址) 2) 127.X.X.X是保留地址，用做循环测试用的。B类 128.0.0.1---191.255.255.254 172.16.0.0---172.31.255.255是私有地址 169.254.X.X是保留地址C类 192.0.0.1---223.255.255.254 192.168.X.X是私有地址D类 224.0.0.1---239.255.255.254 E类 240.0.0.1---247.255.255.254特殊的IP地址： 127.0.0.1 回环地址(表示本机) x.x.x.255 广播地址 x.x.x.0 网络地址

端口号：

正在运行的程序的标识。有效端口：0~65535，其中0~1024系统使用或保留端口。

协议（通信的规则）：

UDP：把数据打包数据有限制不建立连接速度快不可靠TCP：建立连接通道数据无限制速度慢可靠举例： UDP：发短信 TCP：打电话

Socket机制

A:通信两端都应该有Socket对象B:所有的通信都是通过Socket间的IO进行操作的

UDP协议发送和接收数据

发送：创建UDP发送端的Socket对象创建数据并把数据打包发送数据释放资源接收：创建UDP接收端的Socket对象创建数据包用于接收数据接收数据解析数据包释放资源

TCP协议发送和接收数据

发送：创建TCP客户端的Socket对象获取输出流，写数据释放资源接收：创建TCP服务器端的Socket对象监听客户端连接获取输入流，读取数据释放资源

UDP案例

/* * 聊天程序 */public class ChatRoom { public static void main(String[] args) throws IOException { DatagramSocket dsSend = new DatagramSocket(); DatagramSocket dsReceive = new DatagramSocket(12306); SendThread st = new SendThread(dsSend); ReceiveThread rt = new ReceiveThread(dsReceive); Thread t1 = new Thread(st); Thread t2 = new Thread(rt); t1.start(); t2.start(); }}public class SendThread implements Runnable { PRivate DatagramSocket ds; public SendThread(DatagramSocket ds) { this.ds = ds; } @Override public void run() { try { // 封装键盘录入数据 BufferedReader br = new BufferedReader(new InputStreamReader(System.in)); String line = null; while ((line = br.readLine()) != null) { if ("886".equals(line)) { break; } // 创建数据并打包 byte[] bys = line.getBytes(); // DatagramPacket dp = new DatagramPacket(bys, bys.length, // InetAddress.getByName("192.168.12.92"), 12345); DatagramPacket dp = new DatagramPacket(bys, bys.length, InetAddress.getByName("192.168.12.255"), 12306); // 发送数据 ds.send(dp); } // 释放资源 ds.close(); } catch (IOException e) { e.printStackTrace(); } }}public class ReceiveThread implements Runnable { private DatagramSocket ds; public ReceiveThread(DatagramSocket ds) { this.ds = ds; } @Override public void run() { try { while (true) { // 创建一个包裹 byte[] bys = new byte[1024]; DatagramPacket dp = new DatagramPacket(bys, bys.length); // 接收数据 ds.receive(dp); // 解析数据 String ip = dp.getAddress().getHostAddress(); String s = new String(dp.getData(), 0, dp.getLength()); System.out.println("from " + ip + " data is : " + s); } } catch (IOException e) { e.printStackTrace(); } }}

TCP案例

public class UserThread implements Runnable { private Socket s; public UserThread(Socket s) { this.s = s; } @Override public void run() { try { // 封装通道内的流 BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream())); // 为了防止名称冲突 String newName = System.currentTimeMillis() + ".java"; BufferedWriter bw = new BufferedWriter(new FileWriter(newName)); String line = null; while ((line = br.readLine()) != null) { // 阻塞 bw.write(line); bw.newLine(); bw.flush(); } // 给出反馈 BufferedWriter bwServer = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); bwServer.write("文件上传成功"); bwServer.newLine(); bwServer.flush(); // 释放资源 bw.close(); s.close(); } catch (IOException e) { e.printStackTrace(); } }}public class UploadClient { public static void main(String[] args) throws IOException { // 创建客户端Socket对象 Socket s = new Socket("192.168.12.92", 11111); // 封装文本文件 BufferedReader br = new BufferedReader(new FileReader("ReceiveDemo.java")); // 封装通道内流 BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream())); String line = null; while ((line = br.readLine()) != null) { // 阻塞 bw.write(line); bw.newLine(); bw.flush(); } // Socket提供了一个终止，通知服务器我没有数据过来了 s.shutdownOutput(); // 接收反馈 BufferedReader brClient = new BufferedReader(new InputStreamReader(s.getInputStream())); String client = brClient.readLine(); // 阻塞 System.out.println(client); // 释放资源 br.close(); s.close(); }}public class UploadServer { public static void main(String[] args) throws IOException { // 创建服务器Socket对象 ServerSocket ss = new ServerSocket(11111); while (true) { Socket s = ss.accept(); new Thread(new UserThread(s)).start(); } }}

上一篇：java之多态与抽象与接口！！！

下一篇：第五届蓝桥杯JavaA组第三题