osi网络7层架构

不念不忘少年蓝@ 2022-10-13 02:44 132阅读 0赞

一、osi网络7层架构  
ip：网络唯一标识。（internet protocol address）网络互联协议地址。分为网络地址和主机地址。  
port：端口号，每一个网络应用程序都需要一个以上的端口号。（1-65535）。1000以内的不要用。  
osi7层架构

物理层，数据链路层，网络层，传输层，会话层，表示层，应用层。

tcp协议（传输控制协议），保证两个应用程序之间可靠的网络通信。可靠的，低效的。  
telent ftp smtp等  
udp协议（用户数据报文协议）。面向无连接的不可靠的，高效的。  
qq snmp dns 在线视频

二、socket简介  
套接字，用于描述一个ip和端口号绑定的通信会话（socket连接）。每一个网络服务都会打开一个socket连接。  
serverSocket  
位于java的net包下面。

此类实现服务器套接字。服务器套接字等待请求通过网络传入。它基于该请求执行某些操作，然后可能向请求者返回结果。

Socket  
此类实现客户端套接字（也可以就叫“套接字”）。套接字是两台机器间通信的端点。

三、基于TCP协议的socket编程  
创建一个基于tcp协议的scoket服务器  
类 ServerSocket

此类实现服务器套接字。服务器套接字等待请求通过网络传入。它基于该请求执行某些操作，然后可能向请求者返回结果。  
public class TalkServer \{  
public static void main(String\[\] args) throws Exception \{  
//创建一个serversocket在端口7000上，监听客户端请求  
ServerSocket server= new ServerSocket(7000);  
Socket socket = server.accept();//获取socket对象  
//由Scoket对象获得输入流，并构造相应的bufferedReader对象  
BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));  
//由socket对象得到输出流，并构造printWrite对象  
PrintWriter os = new PrintWriter(socket.getOutputStream(), true);  
//由控制台输入构造BufferedReader对象  
BufferedReader sin= new BufferedReader(new InputStreamReader(System.in));  
System.out.println(“client:”+in.readLine());//打印客户端消息  
String line = sin.readLine();//从控制台读取输入消息  
while(!line.equals(“bye”))\{  
//把line返回给client  
os.println(line);  
System.out.println(“server:”+line);  
System.out.println(“client:”+in.readLine());  
line=sin.readLine();//读取下一条消息

}
    	in.close();
    	os.close();
    	sin.close();
    	socket.close();
    	
    }

使用多线程技术完成多服务对多客户端

package com.aaa.tcp;

import java.io.BufferedReader;  
import java.io.IOException;  
import java.io.InputStreamReader;  
import java.io.PrintWriter;  
import java.net.Socket;

public class TalkServerThread implements Runnable \{

private Socket socket;
    
    
    public TalkServerThread(Socket socket) {
    	super();
    	this.socket = socket;
    }
    
    
    @Override
    public void run() {
    	//由Scoket对象获得输入流，并构造相应的bufferedReader对象
    	BufferedReader in;
    	try {
    		in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    		//由socket对象得到输出流，并构造printWrite对象
    		PrintWriter os = new PrintWriter(socket.getOutputStream(), true);
    		//由控制台输入构造BufferedReader对象
    		BufferedReader sin= new BufferedReader(new InputStreamReader(System.in));
    		System.out.println("client:"+in.readLine());//打印客户端消息
    		String line = sin.readLine();//从控制台读取输入消息
    		while(!line.equals("bye")){
    			//把line返回给client
    			os.println(line);
    			System.out.println("server:"+line);
    			System.out.println("client:"+in.readLine());
    			line=sin.readLine();//读取下一条消息
    			
    		}
    		in.close();
    		os.close();
    		sin.close();
    		socket.close();
    	} catch (IOException e) {
    		// TODO Auto-generated catch block
    		e.printStackTrace();
    	}
    	
    
    }

测试类  
package com.aaa.tcp;

import java.io.IOException;  
import java.net.ServerSocket;  
import java.net.Socket;  
import java.util.concurrent.ExecutorService;  
import java.util.concurrent.Executors;

public class MultiSocketServerTest \{

/**
     * @param args
     * @throws Exception 
     */
    public static void main(String[] args) throws Exception {
    	//多个socket连接，但是端口号一致
    	ServerSocket server=new ServerSocket(7000);
    	Socket socket=null;
    	while(true){
    		socket = server.accept();//等待获取来自客户端的socket请求
    		//一旦客户端请求到达，开启一个线程，来跟客户端交互
    		new Thread(new TalkServerThread(socket)).start();
    	}
    	
    	
    }

四、基于UDP协议的socket编程  
InetAddress  
public static void main(String\[\] args) throws Exception \{  
InetAddress localHost = InetAddress.getLocalHost();  
String hostName = localHost.getHostName();  
System.out.println(hostName);  
String hostAddress = localHost.getHostAddress();  
System.out.println(hostAddress);

//获取远程网站的ip
    	InetAddress baidu = InetAddress.getByName("www.baidu.com");
    	System.out.println(baidu.getHostAddress());
    }

使用upd模拟飞秋发送消息  
package com.aaa.network;

import java.io.IOException;  
import java.net.DatagramPacket;  
import java.net.DatagramSocket;  
import java.net.InetAddress;  
import java.net.SocketException;  
import java.net.UnknownHostException;  
import java.util.Date;

/\*\*

*  @author sunshaoshan
 *  @description java 模拟飞秋发送消息
 *  @company AAA软件
 *  2018-11-5下午4:45:53  
    \*/  
    public class FeiQiuTest \{
    
    /\*\*  
    \*TODO  
    \*@param args  
    \*2018-11-5下午4:45:45  
    \*/  
    public static void main(String\[\] args) \{  
    DatagramSocket ds= null;  
    DatagramPacket dp = null;  
    InetAddress localHost;  
    String Version=“1\_lbt4\_0\#128\#000C29D68D8F\#0\#0\#0\#2.5a”;  
    Long id=new Date().getTime();//获取当前系统毫秒  
    String user=“孙韶山”;  
    String host=“sunshaoshan”;  
    //long IPMSG\_SENDMSG = 0x00000020;//发消息  
    long IPMSG\_SENDMSG = 209;//发消息  
    String msg=“I kill you!”;  
    while(true)\{
    
        try {
          	ds=new DatagramSocket();
          	//localHost = InetAddress.getByName("DESKTOP-H5URIFQ");
          	localHost=InetAddress.getLocalHost();
          	String message=Version+":"+id+":"+user+":"+host+":"+IPMSG_SENDMSG+":"+msg;
          	//封装数据报文，2425是飞秋的端口号
          	///1version(IPMSG版本):no(消息编号,可以用系统时间):user(发送消息的用户名):host(发送消息的主机名):command(上述Command常量,可以用|组合多个值):msg(消息内容) 
          	byte[] buff= message.getBytes("gbk");
          	dp = new DatagramPacket(buff, buff.length,localHost,2425);
          	//发送报文
          	ds.send(dp);
          } catch (UnknownHostException e) {
          	e.printStackTrace();
          } catch (SocketException e) {
          	e.printStackTrace();
          } catch (IOException e) {
          	e.printStackTrace();
          }
          }
    
    \}