UDP和TCP协议发送接收数据
发布时间
阅读量：
阅读量
目
录
一.UDP协议发送接收数据(不需要建立连接,不可靠协议)
1.(客户端)发送数据步骤:
2.(服务端)接收数据步骤:
3.实现客户端键盘录入,服务端控制台输出(多线程)
4.实现双方互聊(多线程)
二.TCP协议发送接收数据(必须建立连接,可靠协议,效率稍低)
1.(客户端)发送数据步骤:
2.(服务端)接收数据步骤:
3.实现客户端键盘录入,服务端控制台输出
4.客户端键盘录入,服务端写到文本文件中
5. 客户端读取文档,服务端接收并存入文档且有反馈
一.UDP协议发送接收数据(不需要建立连接,不可靠协议)
1.(客户端)发送数据步骤:
- 创建UDP通讯客户端对象(DatagramSocket)
- 创建数据报包 public DatagramPacket(byte[] buf, int length, InetAddress address,int port)
- 发送 数据
- 释放资源
//创建UDP Socket客户端
DatagramSocket ds = new DatagramSocket();
Scanner sc = new Scanner(System.in);
while (true) {
System.out.println("请输入你要发送的消息");
String msg = sc.nextLine();
byte[] bytes = msg.getBytes();
//创建数据报包 ,下面数据中的"***.***.***.***"更换成接收消息的主机号,"9999"是由接收方设定好的端口号,
DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("***.***.***.***"), 9999);
//发送数据
ds.send(dp);
}
//释放资源
ds.close();2.(服务端)接收数据步骤:
- 创建UDP通讯协议服务器端对象(DatagramSocket) 注意要用有参数构造 指定端口号
- 创建数据报包,作用用来接收数据 // public DatagramPacket(byte[] buf, int length)
- 接收数据 receive(dp) ;
- 解析数据报包,拿出数据 dp.getData() ; dp.getLength() ;
- 释放资源
//创建服务端对象的Socket并指定端口号,此处端口号可自己随意指定
DatagramSocket ds = new DatagramSocket(9999);
//创建数据报包,接收数据
byte[] bytes = new byte[1024];
DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
//接收数据
ds.receive(dp);
//解析数据报包,拿出数据
byte[] data = dp.getData();
//获取数据的实际长度
int length = dp.getLength();
//获取发送方的ip和端口
String ip = dp.getAddress().getHostAddress();
String s = new String(data, 0, length);
System.out.println("B-IP:为" + ip + "给你发来消息" + s);
}
//释放资源
ds.close();3.实现客户端键盘录入,服务端控制台输出(多线程)
当同一个程序中用主线程接收数据,子线程发送数据,即可实现自己(客户端)发送,自己(服务端)接收消息.此时在知晓他人ip号的情况下也可实现给他人发消息(本机写(客户端)发送数据的代码,他人写(服务端)接收数据的代码).这个时候都属于单方面的发送消息,单方面的接收消息,即客户端键盘录入服务器控制台输出.如下为自己即作为客户端又作为服务端的代码实现:
public class Test {
public static void main(String[] args) throws IOException {
//子线程接收消息
new Thread() {
@Override
public void run() {
try {
//创建服务端的Socket并暴露端口号
DatagramSocket ds = new DatagramSocket(9999);
System.out.println("A-服务器已经开启，等待接收收据....");
while (true) {
byte[] bytes = new byte[1024];
DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
//阻塞式方法 此方法在接收到数据报前一直阻塞
ds.receive(dp);
//从数据报包中取出数据
byte[] data = dp.getData();
//获取数据的实际长度
int length = dp.getLength();
//获取发送方的ip和端口
String ip = dp.getAddress().getHostAddress();
String s = new String(data, 0, length);
System.out.println("本地IP:为" + ip + "给你发来消息" + s);
if ("886".equals(s)) {
break;
}
}
ds.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
//主线程发消息
sendMsg();
}
private static void sendMsg() throws IOException {
//1.创建UDP Socket客户端
DatagramSocket ds = new DatagramSocket();
Scanner sc = new Scanner(System.in);
while (true) {
System.out.println("请输入你要发送的消息");
String msg = sc.nextLine();
byte[] bytes = msg.getBytes();
//此处的***.***.***.***更改为自己的主机号
DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("***.***.***.***"), 9999);
ds.send(dp);
if ("886".equals(msg)) {
break;
}
}
ds.close();
}
}4.实现双方互聊(多线程)
**如果要实现双方互聊的情况,那么双方都实现(客户端)发送数据和(服务端)接收数据的功能即可.**A用户的功能实现如下:
public class A {
public static void main(String[] args) throws IOException {
//子线程接收消息
new Thread() {
@Override
public void run() {
try {
//创建服务端的Socket并暴露端口号
DatagramSocket ds = new DatagramSocket(8888);
System.out.println("A-服务器已经开启，等待接收收据....");
while (true) {
byte[] bytes = new byte[1024];
DatagramPacket dp = new DatagramPacket(bytes, bytes.length);
//阻塞式方法 此方法在接收到数据报前一直阻塞
ds.receive(dp);
//从数据报包中取出数据
byte[] data = dp.getData();
//获取数据的实际长度
int length = dp.getLength();
//获取发送方的ip和端口
String ip = dp.getAddress().getHostAddress();
String s = new String(data, 0, length);
System.out.println("B-IP:为" + ip + "给你发来消息" + s);
if ("886".equals(s)) {
break;
}
}
ds.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}.start();
//主线程发消息
sendMsg();
}
private static void sendMsg() throws IOException {
//创建UDP Socket客户端
DatagramSocket ds = new DatagramSocket();
Scanner sc = new Scanner(System.in);
while (true) {
System.out.println("请输入你要发送的消息");
String msg = sc.nextLine();
byte[] bytes = msg.getBytes();
//"***.***.***.***"更换成B用户的主机号
DatagramPacket dp = new DatagramPacket(bytes, bytes.length, InetAddress.getByName("***.***.***.***"), 8888);
ds.send(dp);
if ("886".equals(msg)) {
break;
}
}
ds.close();
}
}B用户的功能实现代码也如上,注意的是发送消息时,主机号写成A用户的.并且A用户和B用户使用同一个端口号. 当然也可以自己和自己互聊,启动两个程序同时执行即可!需要注意的是两个程序代码的发送消息中的ip都写成自己的,并且两个程序的端口号不能设置一致,如果A设置的端口号为8888,B端口设置为9999,那么A程序中的发送数据的端口号需要写成9999,B中写成8888.如此便可以达成互聊的效果!
二.TCP协议发送接收数据(必须建立连接,可靠协议,效率稍低)
1.(客户端)发送数据步骤:
- 创建TCP通讯协议客户端对象(Socket) // public Socket(String host, int port)
- 获取输出流对象
- 写数据到连接通道中
- 释放资源
//创建TCP通讯协议客户端对象(Socket),其中***.***.***.***为接收方的主机号,7777为端口号,可自行定义
Socket sk = new Socket("***.***.***.***", 7777);
//获取输出流对象
OutputStream out = sk.getOutputStream();
out.write("服务器你好！".getBytes());
//读取服务端的反馈
InputStream in = sk.getInputStream();
byte[] bytes = new byte[1024];
int len = in.read(bytes);
String fk = new String(bytes, 0, len);
System.out.println(fk);
//释放资源
sk.close();2.(服务端)接收数据步骤:
- 创建TCP通讯协议服务器端对象(ServerSocket)
- 监听客户端
- 获取输入流对象
- 读取通道中的数据
- 释放资源
// 创建TCP通讯协议服务器端对象(ServerSocket),7777为客户端即发送端定义的.
ServerSocket ss = new ServerSocket(7777);
System.out.println("服务器以开启等待连接.....");
//侦听客户端的连接
Socket sk = ss.accept();
//获取输入流对象
InputStream in = sk.getInputStream();
byte[] bytes = new byte[1024];
int len = in.read(bytes);
String s = new String(bytes, 0, len);
System.out.println(s);
//服务端给客户端一个反馈
OutputStream out = sk.getOutputStream();
out.write("客户端你好".getBytes());
//释放资源
ss.close();3.实现客户端键盘录入,服务端控制台输出
此时客户端一直键盘录入消息,而客户端会一直接收消息!
//客户端的代码实现:
public class TCPClient {
public static void main(String[] args) throws IOException {
//其中***.***.***.***为接收方的主机号也可写自己的主机号,7777为端口号,可自行定义
Socket sk = new Socket("***.***.***.***", 7777);
OutputStream out = sk.getOutputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out));
while (true) {
System.out.println("请输入消息");
String msg = reader.readLine();
writer.write(msg);
writer.newLine();
writer.flush();
if ("886".equals(msg)) {
break;
}
}
sk.close();
}
}
//服务端的代码实现:
public class TCPServer {
public static void main(String[] args) throws IOException {
//7777为客户端即发送端定义的.
ServerSocket ss = new ServerSocket(7777);
System.out.println("服务器以开启等待连接.....");
//侦听客户端的连接
Socket sk = ss.accept();
InputStream in = sk.getInputStream();
//包装通道中字节流
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
while (true) {
String msg = reader.readLine();
System.out.println(msg);
if ("886".equals(msg)) {
break;
}
}
ss.close();
}
}
4.客户端键盘录入,服务端写到文本文件中
//客户端的代码实现:
public class TCPClient {
public static void main(String[] args) throws IOException {
//其中***.***.***.***为接收方的主机号也可写自己的主机号,7777为端口号,可自行定义
Socket sk = new Socket("***.***.***.***", 7777);
OutputStream out = sk.getOutputStream();
BufferedReader reader = new BufferedReader(new InputStreamReader(System.in));
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out));
while (true) {
System.out.println("请输入消息");
String msg = reader.readLine();
writer.write(msg);
writer.newLine();
writer.flush();
if ("886".equals(msg)) {
break;
}
}
sk.close();
}
}
//服务端的代码实现
public class TCPServer {
public static void main(String[] args) throws IOException {
ServerSocket ss = new ServerSocket(7777);
System.out.println("服务器以开启等待连接.....");
//侦听客户端的连接
Socket sk = ss.accept();
InputStream in = sk.getInputStream();
//包装通道中字节流
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
//读取出来写入到msg.txt文件中
BufferedWriter writer = new BufferedWriter(new FileWriter("msg.txt"));
while (true) {
String msg = reader.readLine();
System.out.println(msg);
writer.write(msg);
writer.newLine();
writer.flush();
if ("886".equals(msg)) {
break;
}
}
ss.close();
}
}5. 客户端读取文档,服务端接收并存入文档且有反馈
这个过程实际上就是文件的上传,客户端读取文本文件发送数据到服务器端,服务器端读取数据存储到文本文件中.
//客户端的代码实现:
public class TCPClient {
public static void main(String[] args) throws IOException {
//其中***.***.***.***为接收方的主机号也可写自己的主机号,7777为端口号,可自行定义
Socket sk = new Socket("***.***.***.***", 7777);
OutputStream out = sk.getOutputStream();
//读出文件MyTest.java中的内容
BufferedReader reader = new BufferedReader(new FileReader("MyTest.java"));
//包装通道中的输入流
BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out));
String line = null;
while ((line = reader.readLine()) != null) {
writer.write(line);
writer.newLine();
writer.flush();
}
System.out.println("下来了");
//给服务端手写一个标记
writer.write("over");
writer.newLine();
writer.flush();
//读取服务端的反馈
InputStream in = sk.getInputStream();
byte[] bytes = new byte[1024];
int len = in.read(bytes);
String s = new String(bytes, 0, len);
System.out.println(s);
sk.close();
}
}
//服务端的代码实现:
public class TCPServer {
public static void main(String[] args) throws IOException {
ServerSocket ss = new ServerSocket(7777);
System.out.println("服务器以开启等待连接.....");
//侦听客户端的连接
Socket sk = ss.accept();
InputStream in = sk.getInputStream();
//包装通道中字节流
BufferedReader reader = new BufferedReader(new InputStreamReader(in));
//关联文件,写入到该文件中
BufferedWriter writer = new BufferedWriter(new FileWriter("copy.java"));
String line = null;
while ((line = reader.readLine()) != null) {
if ("over".equals(line)) {
break;
}
//System.out.println(line);
writer.write(line);
writer.newLine();
writer.flush();
}
System.out.println("服务端下来了");
//给客户端一个反馈，告诉客户端文件上传成功
OutputStream out = sk.getOutputStream();
out.write("文件上传成功！".getBytes());
ss.close();
}
}补充:如果想实现双方或多方聊天功能,那么双方都实现客户端和服务端的代码,便可以实现互相聊天的操作!
- UDP协议: 发短信 将数据源和目的地封装成数据包，不需要建立连接； 每个数据报包的大小在限制在64k； 因无连接，是不可靠协议； 不需要建立连接，速度快，效率高
- TCP协议: 打电话 视频 建立连接，形成传输数据的通道； 在连接中进行大数据量传输； 需要连接所以是可靠协议； 必须建立连接，效率会稍低
(小编也在努力学习更多哟!以后再慢慢分享的啦!)
希望对友友们有所帮助!!!!
全部评论 (0)
还没有任何评论哟~