java_网络编程学习笔记(一)

网络概述

网络模型

了解更多OSI模型和TCP/IP模型参考http://blog.csdn.net/yuliu0552/article/details/6711659

IP地址

package cn.wangyu.net;import java.net.InetAddress;
import java.net.UnknownHostException;
import java.util.Arrays;import org.junit.Test;/** * @author JiangMinyan** @version 2016/02/19 10:53:30*/
public class NetTest {@Test//测试IP对象public void testInetAddress() throws UnknownHostException{//获取本机信息InetAddress localHost = InetAddress.getLocalHost();sop(localHost);System.out.println("address: " + localHost.getHostAddress());System.out.println("name: " + localHost.getHostName());fengexian();//获取任意主机信息InetAddress ia = InetAddress.getByName("192.168.21.193");sop(ia);System.out.println("address: " + ia.getHostAddress());System.out.println("name: " + ia.getHostName());fengexian();//获取任意淘宝主机信息
//      InetAddress baidu = InetAddress.getByName("www.baidu.com");InetAddress[] taobao = InetAddress.getAllByName("www.taobao.com");sop(Arrays.asList(taobao));
//      System.out.println("address: " + baidu.getHostAddress());
//      System.out.println("name: " + baidu.getHostName());}public void sop(Object obj){System.out.println(obj);}public void fengexian(){System.out.println("-------------------------------");}
}

TCP/UDP

UDP:

将数据及源和目的封装成数据包中，不需要建立连接。

每个数据包的大小限制在64k以内

由于无连接，不可靠协议

不需要建立连接，速度快

TCP：

建立连接，形成传输数据的通道

在连接中进行大数据传输

通过三次握手进行连接，是可靠连接

(好比如大学点名，老师叫学生名字，学生起立答到，老师叫其坐下三次握手)

必须建立连接，效率会稍低

了解更多TCP/UDPhttp://blog.csdn.net/yipiankongbai/article/details/24435977

Socket

socket就是为网络服务提供的一种机制

通信的两端都有socket

网络通信其实就是socket之间的通信

数据在两个socket之间通过IO传输

了解更多sockethttp://blog.csdn.net/zapldy/article/details/5813984

UDP传输

DataGramSocket与DatagramPacket

建立发送端，接收端

调用Socket的发送接收方法

关闭Socket

发送端与接收端是两个独立的运行程序

发送发:

package cn.wangyu.net;import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;/*** @author JiangMinyan* * @version 2016/02/19 14:20:58*/
public class UDPSendSocket {/*** 需求： 通过UDP传输方式，将一段文字数据发送出去 思路： 1，简历UDPsocket服务 2，提供数据，并将数据封装到数据包中* 3，通过socket服务的发送功能，将数据包发送出去 4，关闭资源* * @throws Exception*/public static void main(String[] args) throws Exception {// 1 创建UDP服务，通过DatagramSocket对象DatagramSocket ds = new DatagramSocket(8989);// 2 确定数据，并封装成数据包byte[] buf = "udp ge men lai le ".getBytes();DatagramPacket packet = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.21.158"), 7080);// 3 通过socket服务，将封装好的数据包发送出去ds.send(packet);// 4 关闭资源ds.close();}
}

接收方:

package cn.wangyu.net;import java.net.DatagramPacket;
import java.net.DatagramSocket;/*** @author JiangMinyan* * @version 2016/02/19 14:21:54*/
public class UDPReceiveSocket {/*** 需求： 用于接收udp协议传输的数据并处理 思路：* 1，定义udpsocket服务.通常会监听一个端口。其实就是给这个接受网络应用程序定义数字标识。 方便于明确那些数据过来该应用程序可以处理。* 2，定义一个数据包，因为要存储接收到的字节数据。 因为数据包对象中有更多功能可以提取字节数据中不同数据信息* 3，通过socket服务的receive方法将收到的数据存入已定义的数据包中 4，通过数据包对象的特有功能。将这些不同的数据取出。打印在控制台上。* 5，关闭资源* * @throws Exception*/public static void main(String[] args) throws Exception {// 1 创建UDP服务，通过DatagramSocket对象DatagramSocket ds = new DatagramSocket(7080);// 2 定义数据包。用于存储数据byte[] buf = new byte[1024];DatagramPacket packet = new DatagramPacket(buf, buf.length);// 3 通过socket服务的receive方法将收到数据存入到数据包中ds.receive(packet);// 4 通过数据包的方法获取其中的数据String ip = packet.getAddress().getHostAddress();String data = new String(packet.getData(), 0, packet.getLength());int port = packet.getPort();System.out.println(ip + "::" + data + "::" + port);// 5 关闭资源ds.close();}
}

注意：可以开启两个Eclipse程序进行试验或者开启两个DOS窗口使用CMD命令。

键盘录入发送方:

package cn.wangyu.net;import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;/*** @author JiangMinyan* * @version 2016/02/19 14:20:58*/
public class UDPSendSocket2 {/*** 需求： 通过UDP传输方式，将一段文字数据发送出去 思路： 1，简历UDPsocket服务 2，提供数据，并将数据封装到数据包中* 3，通过socket服务的发送功能，将数据包发送出去 4，关闭资源* * @throws Exception*/public static void main(String[] args) throws Exception {// 1 创建UDP服务，通过DatagramSocket对象DatagramSocket ds = new DatagramSocket(8989);// 2 确定数据，并封装成数据包BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));String line = null;while((line = bufr.readLine()) != null){if ("886".equals(line)) break;byte[] buf = line.getBytes();DatagramPacket packet = new DatagramPacket(buf, buf.length, InetAddress.getByName("192.168.21.158"), 7080);// 3 通过socket服务，将封装好的数据包发送出去ds.send(packet);}// 4 关闭资源ds.close();}
}

模仿聊天小程序(UDP)

Send类:

package cn.wangyu.net;import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;/*** @author JiangMinyan* * @version 2016/02/19 16:18:49*/
public class Send implements Runnable {private DatagramSocket ds;public Send(DatagramSocket ds) {this.ds = ds;}@Overridepublic void run() {System.out.println("send............");try {BufferedReader buff = new BufferedReader(new InputStreamReader(System.in));String line = null;while ((line = buff.readLine()) != null) {if ("886".equals(line)) {break;}byte[] bytes = line.getBytes();DatagramPacket packet = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("192.168.21.158"), 10005);ds.send(packet);}} catch (Exception e) {throw new RuntimeException("发送失败");}}}

Rece类:

package cn.wangyu.net;import java.net.DatagramPacket;
import java.net.DatagramSocket;/*** @author JiangMinyan* * @version 2016/02/19 16:26:33*/
public class Rece implements Runnable {private DatagramSocket ds;public Rece(DatagramSocket ds) {this.ds = ds;}@Overridepublic void run() {System.out.println("rece............");try {while (true) {byte[] buf = new byte[1024];DatagramPacket packet = new DatagramPacket(buf, buf.length);ds.receive(packet);String ip = packet.getAddress().getHostAddress();String data = new String(packet.getData(), 0, packet.getLength());int port = packet.getPort();System.out.println(ip + "::" + data + "::" + port);}} catch (Exception e) {throw new RuntimeException("接收失败");}}}

Chat类:

package cn.wangyu.net;import java.net.DatagramSocket;/** * @author JiangMinyan** @version 2016/02/19 16:31:22*/
public class Chat {public static void main(String[] args) throws Exception {DatagramSocket send = new DatagramSocket();DatagramSocket rece = new DatagramSocket(10005);new Thread(new Send(send)).start();new Thread(new Rece(rece)).start();}
}

最好把三个文件分别在两台电脑上调式.或者开启两个eclipse改成对应IP。

TCP传输

Socket和ServerSocket

建立客户端和服务端

建立连接后，通过Socket中的IO流进行数据的传输。

关闭socket

客户端与服务端互访。

客户端:

package cn.wangyu.net;import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;/** * @author JiangMinyan** @version 2016/02/22 9:56:24*/
public class TCPClient {/*** 客户端：* 通过查阅socket对象，发现在该对象建立时，就可以去连接指定的主机。* 因为TCP是面向连接的，所以在建立socket服务时，就要有服务端存在* ，并连接成功。形成通路，在该通道进行数据的传输。* * 步骤：* 1 创建socket服务，并指定要连接的主机和端口* @param args*/public static void main(String[] args) throws Exception {//创建客户端socket服务，指定目的主机和端口Socket s = new Socket("192.168.21.158", 10004);//为了发送数据，应该获取socket流中的输出流。OutputStream out = s.getOutputStream();out.write("tcp ge men lai le".getBytes());//获取服务端返回的数据InputStream input = s.getInputStream();byte[] buff = new byte[1024];int len = input.read(buff);System.out.println(new String(buff, 0 , len));s.close();}
}

服务端：

import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;/** * @author JiangMinyan** @version 2016/02/22 9:56:38*/
public class TCPServer {/*** 服务端:* 1 建立服务端的socket服务。ServerSocket(),并监听一个端口* 2 获取连接过来的客户端对象，通过ServerSocket的accept方法，没有连接就会等，所以这个方法是阻塞式的。* 3 客户端如果发送过来数据，那么服务端要使用对应的客户端对象，并获取到该客户端对象的读取流来读取发过来的数据，*   并打印在控制台。* 4 关闭服务端(可选)* @param args*/public static void main(String[] args) throws Exception{//建立服务端socket服务，并监听一个端口。ServerSocket server = new ServerSocket(10004);//通过accept方法获取连接过来的客户端对象Socket socket = server.accept();String ip = socket.getInetAddress().getHostAddress();System.out.println(ip + "........");//获取客户端发送过来的数据InputStream input = socket.getInputStream();byte[] buf = new byte[1024];int len  = input.read(buf);//向客户端返回数据OutputStream output = socket.getOutputStream();output.write("ni lai le a".getBytes());socket.close();System.out.println(new String (buf, 0 ,len));}
}

TCP小练习:

/**
* 需求：
* 建立一个文本转换服务器。客户端给服务端发送文本，服务端将文本转成大写在返回给客户端
* 而且客户端可以不断的进行文本转换，当客户端输入over时，转换结束。
*/
客户端:

package cn.wangyu.net;import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;/** * @author JiangMinyan** @version 2016/02/22 10:34:23*/
public class TransClient {public static void main(String[] args) throws Exception{Socket client = new Socket("192.168.21.158", 10005);//定义读取键盘数据的流对象BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));//定义目的，将数据写到socket输出流。发给服务端BufferedWriter bufOut = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));//定义一个socket读取流，读取服务端返回的大写信息BufferedReader bufIn = new BufferedReader(new InputStreamReader(client.getInputStream()));String line  = null;while((line = bufr.readLine()) != null){if ("over".equals(line)) {break;}bufOut.write(line);bufOut.newLine();bufOut.flush();String str = bufIn.readLine();System.out.println("server:" + str);}bufr.close();client.close();}
}

服务端:

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;public class TransServer {public static void main(String[] args) throws Exception{ServerSocket server = new ServerSocket(10005);Socket client = server.accept();String ip = client.getInetAddress().getHostAddress();System.out.println(ip + "......connected");//读取socket流中的数据。BufferedReader bufIn = new BufferedReader(new InputStreamReader(client.getInputStream()));//目的。socket输出流，将大写数据写入到socket输出流，并发送给客户端。BufferedWriter bufOut = new BufferedWriter(new OutputStreamWriter(client.getOutputStream()));String line = null;while((line = bufIn.readLine()) != null){System.out.println(line);bufOut.write(line.toUpperCase());bufOut.newLine();bufOut.flush();}client.close();server.close();}
}