引言:网络编程作为开发服务端和客户端必不可少的技术之一,在Java中也实现的十分完备,今天对Java的网络编程方面的只是做一个简单的总结,方便以后学习:
一:什么是网络编程?
1:概念:通过使用套接字来达到进程间通信目的的编程就是网络编程。windows提供的基于网络编程的就是套接字也就是winsock,同时Winpcap也是一个比较方便的工具。
2:几个常用概念:
网络模型:描述网络的结构原理和工作原
OSI参考模型:七层
Internet网络模型:四层
网络协议:指定层上进行数据交换的规则。
Internet的网络层协议:IP协议;DNS协议(辅助协议)
Internet的传输层协议:TCP协议,UDP协议
3:Java的Socket通信模型:
相关类介绍:
- A:ServerSocket:用java.net.ServerSocket实现java服务通过TCP/IP监听客户端连接‘;
创建监听指定端口号:
ServerSocket serverSocket = new ServerSocket(9000);
要获取请求的连接需要用ServerSocket.accept()方法。该方法返回一个Socket类,该类具有普通java Socket类的所有特性。每个调用了accept()方法的ServerSocket都只获得一个连接;
Socket socket = ServerSocket.accept();
- B:Socket:当我们想要在Java中使用TCP/IP通过网络连接到服务器时,就需要创建java.net.Socket对象并连接到服务器
创建连接到指定地址和端口的Socket;
Socket socket = new Socket("78.46.84.171", 80);
通过Socket发送数据:
OutputStream out = socket.getOutputStream();
out.write("some data".getBytes());
out.flush();
out.close();
不要忘记调用输出流的flush()方法;操作系统底层的TCP/IP实现会先将数据放入一个更大的数据缓存块中,而缓存块的大小是与TCP/IP的数据包大小相适应的。(译者注:调用flush()方法只是将数据写入操作系统缓存中,并不保证数据会立即发送)
通过Socket读取数据
InputStream in = socket.getInputStream();
int data = in.read();
需要注意的是,从Socket的输入流中读取数据并不能读取文件那样,一直调用read()方法直到返回-1为止,因为对Socket而言,只有当服务端关闭连接时,Socket的输入流才会返回-1,而是事实上服务器并不会不停地关闭连接。假设我们想要通过一个连接发送多个请求,那么在这种情况下关闭连接就显得非常愚蠢。
因此,从Socket的输入流中读取数据时我们必须要知道需要读取的字节数,这可以通过让服务器在数据中告知发送了多少字节来实现,也可以采用在数据末尾设置特殊字符标记的方式连实现。
- C:URL和URLConnection类
在java.net包中包含两个有趣的类:URL类和URLConnection类。这两个类可以用来创建客户端到web服务器(HTTP服务器)的连接,当然也可建立客户端可本地文件之间的连接,
URL url = new URL("http://jenkov.com");创建一个到到改地址的URL
URLConnection urlConnection = url.openConnection()
InputStream input = urlConnection.getInputStream();
int data = input.read();
while(data != -1){
System.out.print((char) data);
data = input.read();
}
input.close();
- D:InetAddress类:是 Java 对 IP 地址的封装。里面包含了很多关于ID地址的信息;这个类的实例经常和 UDP DatagramSockets 和 Socket,ServerSocket 类一起使用。
- E:DatagramSocket代表UDP协议的Socket,DatagramSocket本身只是码头,不维护状态,不能产生IO流,它的唯一作用就是接收和发送数据报,Java使用DatagramPacket来代表数据报,DatagramSocket接收和发送的数据都是通过DatagramPacket对象完成的。
- DatagramPacket:基于UDP的数据包类,里面可以填写很多信息,地址,端口,数据等;
.由这两个类所有构成的网络链接是基于UDP协议,是一种不可靠的协议。
二:具体代码实现:
1:基于TCP的客服端和服务端通信:
服务端代码:
public class Server {
public static void main(String[] args) {
try {
//创建一个服务端监听8888端口
ServerSocket server = new ServerSocket(8888);
//调用accept方法开始监听,等待客户端建立连接
System.out.println("服务段开始监听...............");
Socket socket = server.accept();
InputStream in = socket.getInputStream();
InputStreamReader reader = new InputStreamReader(in);
BufferedReader buff = new BufferedReader(reader);
String line=null;
while((line=buff.readLine())!=null){
System.out.println("我是服务端:客户端说:"+line);
}
socket.shutdownInput();
OutputStream out = socket.getOutputStream();
PrintWriter rw = new PrintWriter(out);
rw.write("你好客户端呀!!!!");
rw.close();
buff.close();
reader.close();
in.close();
server.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
客户端代码:
public class Client {
public static void main(String[] args) {
try {
Socket client = new Socket("127.0.0.1",8888);
OutputStream out = client.getOutputStream();
PrintWriter pw = new PrintWriter(out);
pw.write("用户名:admin;密码:123");
pw.flush();
//记住关闭
client.shutdownOutput();
/**
* 读取服务端发送来的信息
*/
InputStream in = client.getInputStream();
InputStreamReader reader = new InputStreamReader(in);
BufferedReader buf = new BufferedReader(reader);
int data = buf.read();
while(data!=-1){
System.out.print((char)data);
data=buf.read();
}
buf.close();
reader.close();
in.close();
pw.close();
out.close();
client.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
2:基于UDP的客服端和服务端连接:
服务端:
public class Server {
public static void main(String[] args) throws IOException {
try {
//1:创建服务的端的Socket并指定端口
DatagramSocket socket = new DatagramSocket(8800);
byte[] arr = new byte[1024];
DatagramPacket packet = new DatagramPacket(arr, arr.length);
System.out.println("服务端已经打开了:");
socket.receive(packet);
String str = new String(arr);
System.out.println(str);
//1:向客户端发送信息时,也需要知道客户端的地址端口号等信息
InetAddress address = packet.getAddress();
int port1 = packet.getPort();
System.out.println(port1+"==============");
byte[] arr1 = "欢迎您".getBytes();
DatagramPacket datapacketR = new DatagramPacket(arr1,arr1.length,address,port1);
socket.send(datapacketR);
socket.shutdown();
} catch (SocketException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
客户端:
public class Client {
public static void main(String[] args) throws IOException {
//1:创建服务的端的地址,并定义端口号,并定义数据
InetAddress inetAddress = InetAddress.getByName("localhost");
int port = 8800;
byte[] bytes = "用户名:陈鹏,密码:1234".getBytes();
//2:创建数据报,包含发送的地址信息
DatagramPacket datapacket = new DatagramPacket(bytes, bytes.length,inetAddress,port);
//3:创建Socket
DatagramSocket socket = new DatagramSocket();
socket.send(datapacket);
//接受服务端发送来的信息
byte[] arr = new byte[1024];
DatagramPacket datapacketR = new DatagramPacket(arr,arr.length);
socket.receive(datapacketR);
String data = new String(arr);
System.out.println("我是客户端,服务器端响应的数据是:"+data);
}
}
三:自定协议:
需要考虑三点:
- 1:客户端到服务端的往返通讯
- 1.在分开往返中发送头信息;
- 2.将消息分成更小的数据块。
- 2:区分请求结束和响应结束。
- 1:在请求头中包含请求信息长度
- 2:在请求体中增加标志位
- 3:防火墙穿透
- 1:基于HTTP协议上建立协议;