* 一、网络编程中有两个主要的问题: * 1.如何准确地定位网络上地一台或多态主机(IP);定位主机上地特定应用(端口号) * 2.找到主机后如何可靠高效地进行网络传输 * * 二、网络编程中的两个要素: * 1.对应问题一:IP和端口号 * 2.对应问题二:提供网络通信协议:TCP/IP参考模型(应用层、传输层、网络层、物理+数据链路层) * * * 三、通信要素:Ip和端口号 * 1.IP:唯一标识Internet上的计算机(通信实体) * 2.在java中使用InetAddress类代表IP * 3.Ip分类:IpV4和Ipv6:万维网和局域网 * 4.域名:www.baidu.com www.bilibili.com 因为ip地址不容易记忆 * 域名可以是我们不用去记忆复杂的IP地址 * 在搜索引擎上面输入域名如:www.baidu.com 此时就会送到DNS(域名解析器) 然后解析出Ip地址 * * * 我们在hosts写域名 和IP地址也是同样的道理 如果输入这个域名 则指向固定的ip地址 * * 5.本地回路地址:127.0.0.1对应着localhost * * 6.如何实例化InetAddress:两个方法:getByName(String host)、getLocalHost() * * 7.端口号标识正在计算机上运行的进程(程序) * 不同的进程有不同的端口号 * 被规定为一个16位的整数0~65535 * 端口号分类: * 公认端口号:0~1023.http-80 FTP-21 Telnet-23 * 注册端口号:1024~49151分配给用户进程或应用程序,如Tomcat-8080 mysql-3306 oracle-1521 * 动态/私有端口号:49152~65535 * 端口号与Ip地址组合得出一个网络套接字:Socket 网络编程的核心
1.InetAdress实例化:
public class InetAddressTest { public static void main(String[] args){ try { InetAddress inet1=InetAddress.getByName("192.168.10.14"); System.out.println(inet1); InetAddress inet2=InetAddress.getByName("www.bilibili.com"); System.out.println(inet2); InetAddress inet3=InetAddress.getByName("127.0.0.1"); System.out.println(inet3); InetAddress inet4=InetAddress.getLocalHost(); System.out.println(inet4); //getHostName() System.out.println(inet2.getHostName()); //getHostAddress System.out.println(inet2.getHostAddress()); } catch (UnknownHostException e) { e.printStackTrace(); } } }
2.TCP网络编程:
* TCP协议: * 使用TCP协议前,须先建立TCP连接,形成传输数据通道 * 传输前,采用“三次握手”方式,点对点通信,是可靠的 * TCP协议进行通信的两个应用进程:客户端、服务端 * 在连接中可进行大量的数据传输 * 传输完毕,需释放已建立的连接、效率低 (四次挥手) * 比如:打电话
//实现TCP的网络编程 //举例一:客户端发送信息给服务端,服务端将数据显示在控制台上
//客户端 @Test public void client(){ Socket socket= null; OutputStream os = null; try { //创建Socket对象,指明服务器端的IP和端口号 InetAddress inet=InetAddress.getByName("127.0.0.1"); socket = new Socket(inet,8899); //获取一个输入流,用于输出数据 os = socket.getOutputStream(); //写入数据的操作 os.write("你好 我是本机的客户端".getBytes()); } catch (IOException e) { e.printStackTrace(); } finally { if(os!=null){ try { os.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket!=null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } @Test public void server(){ Socket socket= null; InputStream is = null; ByteArrayOutputStream baos=null; try { //1.创建服务器端的ServerSocket,指明自己的端口号 ServerSocket ss=new ServerSocket(8899); //2.调用accept()表示接收来自于客户端的socket socket = ss.accept(); //3.获取输入流 is = socket.getInputStream(); //可能会出现乱码 // byte[] cbuf=new byte[1024]; // int len; // while((len=is.read(cbuf))!=-1){ // String str=new String(cbuf,0,len); // System.out.println(str); // } //4.读取输入流中的数据 baos=new ByteArrayOutputStream(); byte[] buffer=new byte[5]; int len; while((len=is.read(buffer))!=-1){ baos.write(buffer,0,len); } System.out.println(baos.toString()); System.out.println("收到了来自于:"+socket.getInetAddress().getHostAddress()+"的数据"); } catch (IOException e) { e.printStackTrace(); } finally { //5.关闭资源 if(baos!=null){ try { baos.close(); } catch (IOException e) { e.printStackTrace(); } } if(is!=null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket!=null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } }
例子二:实现客户端传给服务器一张照片 服务器收到照片后保存到本地并返回信息给客户端
@Test public void client(){ Socket socket= null; OutputStream os = null; FileInputStream fis= null; InputStream is = null; ByteArrayOutputStream baos= null; try { //1.指明ip地址 InetAddress inet=InetAddress.getByName("127.0.0.1"); //2.提供ip和端口号 确定一个套接字socket socket = new Socket(inet,8890); //3.获取输入流,用于输出数据 os = socket.getOutputStream(); //4.文件对象实例化 File file=new File("向涵之.jpg"); //5.流的实例化 fis = new FileInputStream(file); //6.将数据传输进去 byte[] cbuf=new byte[1024]; int len; while((len=fis.read(cbuf))!=-1){ os.write(cbuf,0,len); } //关闭数据的输出 告诉服务器端 说我的图片已经传完了 避免服务器端一直等待 socket.shutdownOutput(); //接收来自于服务器端的数据,并显示到控制台上 //1.获取输出流,用于接收数据 is = socket.getInputStream(); //因为此时要传输的是字符串(中文是占三个字节的)如果不使用ByteArrayOutputStream 有可能会乱码 //ByteArrayOutputStream的作用是将写入的部分字符存在数组中,等完全读完后再一起输出 这样子就不会引起乱码 baos = new ByteArrayOutputStream(); //数据的读写操作 byte[] cbuf1=new byte[5]; int len1; while((len1=is.read(cbuf1))!=-1){ baos.write(cbuf1,0,len1); } System.out.println(baos); } catch (IOException e) { e.printStackTrace(); } finally { if(baos!=null){ try { baos.close(); } catch (IOException e) { e.printStackTrace(); } } if(is!=null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } if(fis!=null){ try { fis.close(); } catch (IOException e) { e.printStackTrace(); } } if(os!=null){ try { os.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket!=null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } } } @Test public void server(){ ServerSocket ss= null; Socket socket = null; InputStream is = null; FileOutputStream fos= null; OutputStream os = null; try { //指明服务的端口号 ss = new ServerSocket(8890); //接收来自指定端口号的套接字 socket = ss.accept(); //获取输入流 用来接收数据 is = socket.getInputStream(); //实例化文件对象 File file=new File("向涵之9.jpg"); //实例化流对象 fos = new FileOutputStream(file); //数据的读写操作 byte[] cbuf=new byte[1024]; int len; while((len=is.read(cbuf))!=-1){ fos.write(cbuf,0,len); } System.out.println("图片传输完成"); os = socket.getOutputStream(); os.write("我已接收到向涵之图片".getBytes()); } catch (IOException e) { e.printStackTrace(); } finally { if(os!=null){ try { os.close(); } catch (IOException e) { e.printStackTrace(); } } if(fos!=null){ try { fos.close(); } catch (IOException e) { e.printStackTrace(); } } if(is!=null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } if(socket!=null){ try { socket.close(); } catch (IOException e) { e.printStackTrace(); } } if(ss!=null){ try { ss.close(); } catch (IOException e) { e.printStackTrace(); } } } }
3.UDP的网络编程:
* UDP协议 * 将数据报、源、目的封装成数据包,不需要建立连接 * 每个数据报的大小限制在64K内 * 发送不管对方是否准备好,接收方收到也不确认,故是不可靠的连接 * 可以广播发送 * 发送数据结束时无需释放资源,开销小,速度快 * 比如看网络视频 发短信 发电报 发导弹
UDP网络编程的例子:
@Test public void sender(){ DatagramSocket socket= null; try { socket = new DatagramSocket(); String str="我是UDP方式发送的导弹"; byte[] data=str.getBytes(); InetAddress inet=InetAddress.getLocalHost(); DatagramPacket packet=new DatagramPacket(data,0,data.length,inet,9090); socket.send(packet); } catch (IOException e) { e.printStackTrace(); } finally { if(socket!=null){ socket.close(); } } } @Test public void receiver(){ DatagramSocket socket= null; try { socket = new DatagramSocket(9090); byte[] buffer=new byte[100]; DatagramPacket packet=new DatagramPacket(buffer,0,buffer.length); socket.receive(packet); System.out.println(new String(packet.getData(),0,packet.getLength())); } catch (IOException e) { e.printStackTrace(); } finally { if(socket!=null){ socket.close(); } } }
4.URL网络编程:
* 1.URL:统一资源定位符,对应着互联网的某一资源地址 * 2.格式: * https://www.bilibili.com/video/BV1Qb411g7cz?p=627&spm_id_from=pageDriver * 协议 域名(主机名加端口号) 资源地址 参数列表
常用方法:
public class URLTest { public static void main(String[] args) { try { URL url=new URL("https://www.bilibili.com/video/BV1Qb411g7cz?p=627&spm_id_from=pageDriver"); /* public String getProtocol() 获取该主机的协议名 public String getHost() 获取该URL的主机名 public String getPort() 获取该URL的端口号 public String getPath() 获取该URL的文件路径 public String getFile() 获取该URL的文件名 public String getQuery() 获取该URL的查询名 */ //public String getProtocol() 获取该主机的协议名 System.out.println(url.getProtocol()); //public String getHost() 获取该URL的主机名 System.out.println(url.getHost()); //public String getPort() 获取该URL的端口号 System.out.println(url.getPort()); //public String getPath() 获取该URL的文件路径 System.out.println(url.getPath()); //public String getFile() 获取该URL的文件名 System.out.println(url.getFile()); //public String getQuery() 获取该URL的查询名 System.out.println(url.getQuery()); } catch (MalformedURLException e) { e.printStackTrace(); } } }
URL编程用例一:
public class URLTest1 { public static void main(String[] args){ HttpURLConnection urlConnection = null; InputStream is = null; FileOutputStream fos= null; try { URL url=new URL("http://img.jutoula.com/201912/24/133207973.jpg"); urlConnection = (HttpURLConnection) url.openConnection(); urlConnection.connect(); is = urlConnection.getInputStream(); fos = new FileOutputStream("向涵之.jpg"); byte[] cbuf=new byte[1024]; int len; while((len=is.read(cbuf))!=-1){ fos.write(cbuf,0,len); } System.out.println("下载完成"); } catch (IOException e) { e.printStackTrace(); } finally { if(fos!=null){ try { is.close(); } catch (IOException e) { e.printStackTrace(); } } if(is!=null){ try { fos.close(); } catch (IOException e) { e.printStackTrace(); } } if(urlConnection!=null){ urlConnection.disconnect(); } } } }