Java之网络编程TCP&DUP

1.TCP和UDP

在java中网络程序有两种协议：TCP和UDP，TCP通过握手协议进行可靠的连接，UDP则是不可靠连接。

UDP：将数据，数据源，数据目的封装组成数据包中，不需要建立连接，不可靠协议，但是速度快，每个数据包大小限制在64k内

TCP：建立连接，形成传输数据的通道，在连接中进行大数据量的传输，通过三次握手完成连接，可靠，效率稍低。

2.UDP/TCP通信简单Demo

UPD通信叫发送端和接收端

<span style="font-family:KaiTi_GB2312;">public static void main(String[] args) throws Exception
{
//1，创建udp服务。通过DatagramSocket对象。
DatagramSocket ds = new DatagramSocket();
BufferedReader bufr = new BufferedReader(new InputStreamReader(System.in));
String line = null;
while((line=bufr.readLine())!=null){
byte[] buf = line.getBytes();
//2，确定数据，并封装成数据包
DatagramPacket dp = new DatagramPacket(buf,buf.length,InetAddress.getByName("192.168.1.255"),10001);
//3，通过socket服务，将已有的数据包发送出去。通过send方法。
ds.send(dp);
//4，关闭资源。
ds.close();
}
public static void main(String[] args) throws Exception
{
//1,创建udp socket，建立端点。
DatagramSocket ds = new DatagramSocket(10001);
//2,定义数据包。用于存储数据。
byte[] buf = new byte[1024];
DatagramPacket dp = new DatagramPacket(buf,buf.length);
//3，通过服务的receive方法将收到数据存入数据包中。
ds.receive(dp);//阻塞式方法。
//4，通过数据包的方法获取其中的数据。
String ip = dp.getAddress().getHostAddress();
String data = new String(dp.getData(),0,dp.getLength());                                                           //5，关闭资源
<span style="white-space:pre">	</span>ds.close();
}
}</span>

TCP通信叫服务端和客户端。tcp的传输的客户端和服务端的互访

<span style="font-family:KaiTi_GB2312;">1, tcp分客户端和服务端。
2，客户端对应的对象是Socket。服务端对应的对象是ServerSocket。
3, 通过查阅socket对象，发现在该对象建立时，就可以去连接指定主机。
4, 因为tcp是面向连接的。所以在建立socket服务时，就要有服务端存在，并连接成功。形成通路后，在该通道进行数据的传输。
客户端</span><span style="font-family: KaiTi_GB2312;">步骤：</span><span style="font-family:KaiTi_GB2312;">
1，建立socket服务。指定要连接主机和端口。
2，获取socket流中的输出流。将数据写到该流中。通过网络发送给服务端。
3，获取socket流中的输入流，将服务端反馈的数据获取到，并打印。
4，关闭客户端资源。
class  TCPClient
{
public static void main(String[] args) throws Exception
{
//创建客户端的socket服务。指定目的主机和端口
Socket s = new Socket("192.168.1.254",10003);	                                           <span style="white-space:pre">	</span>
//为了发送数据，应该获取socket流中的输出流。
OutputStream out = s.getOutputStream();<span style="white-space:pre">																		</span>
out.write("服务端，你好".getBytes());<span style="white-space:pre">		</span>
<span style="white-space:pre">		</span>InputStream in = s.getInputStream();
<span style="white-space:pre">		</span>byte[] buf = new byte[1024];
<span style="white-space:pre">		</span>int len = in.read(buf);
<span style="white-space:pre">		</span>System.out.println(new String(buf,0,len));
<span style="white-space:pre">		</span>s.close();
}
}

服务端:
1，建立服务端的socket服务。ServerSocket();并监听一个端口。
2，获取连接过来的客户端对象。通过ServerSokcet的 accept方法。没有连接就会等，所以这个方法阻塞式的。
3，客户端如果发过来数据，那么服务端要使用对应的客户端对象，并获取到该客户端对象的读取流来读取发过来的数据。
4，关闭服务端。（可选）
class  TCPServer
{
public static void main(String[] args) throws Exception
{
//建立服务端socket服务。并监听一个端口。
ServerSocket ss = new ServerSocket(10003);

//通过accept方法获取连接过来的客户端对象。
Socket s = ss.accept();
<span style="white-space:pre">		</span>String ip = s.getInetAddress().getHostAddress();
<span style="white-space:pre">		</span>System.out.println(ip+"....connected");
<span style="white-space:pre">		</span>InputStream in = s.getInputStream();
<span style="white-space:pre">		</span>byte[] buf = new byte[1024];
<span style="white-space:pre">		</span>int len = in.read(buf);
<span style="white-space:pre">		</span>System.out.println(new String(buf,0,len));
<span style="white-space:pre">		</span>OutputStream out = s.getOutputStream();
<span style="white-space:pre">		</span>Thread.sleep(10000);
<span style="white-space:pre">		</span>out.write("哥们收到,你也好".getBytes());
<span style="white-space:pre">		</span>s.close();
<span style="white-space:pre">		</span>ss.close();
}
}
</span>

3.其他Demo

<span style="font-family:KaiTi_GB2312;">import java.io.*;
import java.net.*;

class  TextClient
{
public static void main(String[] args) throws Exception
{
Socket s = new Socket("192.168.1.254",10006);
BufferedReader bufr = new BufferedReader(new FileReader("IPDemo.java"));
PrintWriter out = new PrintWriter(s.getOutputStream(),true);
String line = null;
while((line=bufr.readLine())!=null)
{
out.println(line);
}
s.shutdownOutput();//关闭客户端的输出流。相当于给流中加入一个结束标记-1.
BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
String str = bufIn.readLine();
System.out.println(str);
bufr.close();
s.close();
}
}
class  TextServer
{
public static void main(String[] args) throws Exception
{
ServerSocket ss = new ServerSocket(10006);

Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();
System.out.println(ip+"....connected");
BufferedReader bufIn = new BufferedReader(new InputStreamReader(s.getInputStream()));
PrintWriter out  = new PrintWriter(new FileWriter("server.txt"),true);
String line = null;
while((line=bufIn.readLine())!=null)
{
out.println(line);
}
PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
pw.println("上传成功");
out.close();
s.close();
ss.close();
}
}</span>