Socket编程
Socket编程ip和端口号:???
IP和端口号组成网络地址
IP(Internet Protocol),网络之间互连的协议,IP地址是区分不同计算机的唯一标识
端口号是计算机逻辑通讯接口,不同的应用程序用不同的端口,网络应用程序的区分标识
端口号一般使用2个字节(16bit)进行编号,最多可以有65536个端口,只有整数,范围是从0 到65535
第一类:公认端口(Well Known Ports):从0到1023,它们紧密绑定(binding)于一些服务。通常这些端口的通讯明确表明了某种服务的协议,例如:80端口实际上总是HTTP通讯。
? 第二类:注册端口(Registered Ports):从1024到49151。它们松散地绑定于一些服务。也就是说有许多服务绑定于这些端口,这些端口同样用于许多其它目的。例如:许多系统处理动态端口从1024左右开始。
? 第三类:动态和/或私有端口(Dynamic and/or Private Ports):从49152到65535。理论上,不应为服务分配这些端口。实际上,机器通常从1024起分配动态端口
TCP与UDP:
网络7层协议:物理层,数据链路层,网络层,传输层,会话层,表示层,应用层
传输层的两个主要协议
TCP(Transmission Control Protocol)协议:传输控制协议,提供可靠无差错的数据传输,速度慢,占用系统资源高
UDP(User Datagram Protocol)协议:用户数据报协议,不可靠的数据传输,速度快,较安全。
Socket编程原理(基于TCP):
服务器端
(1) 创建ServerSocket对象,绑定监听端口;
(2) 通过accept()方法监听客户端请求;
(3) 连接建立后,通过输入流读取客户端发送的请求信息;
(4) 通过输出流向客户端发送相应信息;
(5) 关闭响应资源。
客户端
(1) 创建Socket对象,指明需要连接的服务器地址和端口;
(2) 连接建立后,通过输出流向服务器端发送请求信息;
(3) 通过输入流获取服务器端返回的响应信息;
(4) 关闭响应资源。
具体代码实现:
简单示例:
服务器:
try {
ServerSocket server = new ServerSocket(9000);
System.out.println(“服务器已经运行,等待客户端信息!”);
Socket socket = server.accept();
BufferedReader in = new BufferedReader(
new InputStreamReader(socket.getInputStream()));
PrintWriter out = new PrintWriter(socket.getOutputStream(),true);
out.flush();
String clientMsg=in.readLine();
System.out.println(“客户端说:”+clientMsg);
out.println(“你好客户端:我是服务器,你的消息已经收到!”);
} catch (IOException e) {
e.printStackTrace();
}finally{
}
客户端:
Socket socket=null;
PrintWriter out=null;
BufferedReader reader=null;
try {
socket = new Socket(“127.0.0.1”,9000);
out = new PrintWriter(socket.getOutputStream(),true);
//print和write 重写了抽象类Writer里面的write方法
out.println(“你好服务器:我是客户端”);
out.flush();
reader = new BufferedReader(
new InputStreamReader(socket.getInputStream()));
String serverMsg=reader.readLine();
System.out.println(“服务器回话:”+serverMsg);
} catch (Exception e) {
e.printStackTrace();
} finally{
try {
out.close();
reader.close();
socket.close();
}
catch (IOException e)
{e.printStackTrace(); }
}
模拟聊天:
服务器:
try {
ServerSocket serverSocket= new ServerSocket(9000);
Socket socket = serverSocket.accept();
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
Scanner sc = new Scanner(System.in);
PrintWriter printWriter =new PrintWriter(socket.getOutputStream(),true);
while(true){
String s = br.readLine();
System.out.println(“客户端说:”+s);
if(s.contains(“借钱”)){
printWriter.println(“你被拉入黑名单”);
break;
}
String next = sc.next();
printWriter.println(next);
printWriter.flush();
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
客户端:
try {
Socket s=new Socket(“127.0.0.1”,9000);
PrintWriter pw = new PrintWriter(s.getOutputStream(),true);
Scanner sc = new Scanner(System.in);
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(s.getInputStream()));
while(true){
String next = sc.next();
pw.println(next);
pw.flush();
String s1 = bufferedReader.readLine();
System.out.println(“服务器说:”+s1);
if(s1.contains(“黑名单”)){
break;
}
}
} catch (UnknownHostException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
UDP程序原理
客户端:?
??? 1) 创建客户端 DatagramSocket 类 + 指定的发送端口?
??? 2) 准备数据 以字节数组的形式?
??? 3) 打包 DatagramPacket+服务器端的地址和端口?
??? 4) 发送?
??? 5) 释放资源
服务器端?
??? 1) 创建服务端 DatagramSocket 类 + 指定的接收端口?
??? 2) 准备接收数据的容器 以字节数组的形式封装为DatagramPacket?
??? 3) 包 接收数据?
??? 4) 分析?
??? 5) 释放资源
主要类及方法:
DatagramSocket类主要用于实现信息的发送和接收 。主要方法如下:
public DatagramSocket()
构造DatagramSocket对象,不指定监听的端口
public DatagramSocket(int port)
构造DatagramSocket对象,同时指定监听的端口
public void send (DatagramPacket p)
发送数据报
public void receive(DatagramPacket p)
接收数据报
DatagramPacket类用于包装需要发送或接收的信息
public DatagramPacket(byte[] buf,int length)
用来接收长度为 length 的数据包,length 参数必须小于等于 buf.length
public DatagramPacket(byte[]
buf,int? length,InetAddress
address,int port)
构造数据报包,用来将长度为 length 的包发送到指定主机上的指定端口号
public byte[] getData()
返回接收数据
public int getLength()
返回要发送或接收数据的长度
具体代码实现:
示例代码:
服务器端:
DatagramSocket ds = null;
byte[] buf = new byte;
try {
ds = new DatagramSocket();
String info = “hello qy71…”;
DatagramPacket dp= new DatagramPacket(info.getBytes(), info.getBytes().length,
InetAddress.getByName(“localhost”), 3000);
ds.send(dp);
} catch (Exception e) {
e.printStackTrace();
}finally{
ds.close();
}
客户端:
DatagramSocket ds = null;
byte[] buf = new byte;
try {
ds = new DatagramSocket(3000);
DatagramPacket dp = new DatagramPacket(buf,1024);
ds.receive(dp);
String str = new String(buf,0,dp.getLength());
System.out.println(“收到消息:”+str);
}catch(Exception e){
e.printStackTrace();
}finally{
ds.close();
}
注意事项:先启动客户端,receive方法在接收到数据报前一直阻塞。再运行服务器端。
总结:
TCP和UDP是Java网络编程中的传输方式。TCP提供两台计算机之间可靠无差错的数据传输,但资源消耗较大,性能和效率较低;UDP不保证可靠数据的传输,但资源消耗小,性能和效率较高。在实际网络编程中建议根据系统的特点和需要,具体选择合适的方式
文档来源:51CTO技术博客https://blog.51cto.com/u_2096101/3187489
页:
[1]