开发笔记:osi网络7层架构

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

物理层&＃xff0c;数据链路层&＃xff0c;网络层&＃xff0c;传输层&＃xff0c;会话层&＃xff0c;表示层&＃xff0c;应用层。

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

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

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

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

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

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

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


}


}

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

//获取远程网站的ip
InetAddress baidu &＃61; 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;

/**

• &＃64;author sunshaoshan

• &＃64;description java 模拟飞秋发送消息

• &＃64;company AAA软件

• 2018-11-5下午4:45:53
  */
  public class FeiQiuTest {

  /**
  *TODO
  *&＃64;param args
  *2018-11-5下午4:45:45
  */
  public static void main(String[] args) {
  DatagramSocket ds&＃61; null;
  DatagramPacket dp &＃61; null;
  InetAddress localHost;
  String Version&＃61;“1_lbt4_0#128#000C29D68D8F#0#0#0#2.5a”;
  Long id&＃61;new Date().getTime();//获取当前系统毫秒
  String user&＃61;“孙韶山”;
  String host&＃61;“sunshaoshan”;
  //long IPMSG_SENDMSG &＃61; 0x00000020;//发消息
  long IPMSG_SENDMSG &＃61; 209;//发消息
  String msg&＃61;“I kill you!”;
  while(true){

  try {
ds&＃61;new DatagramSocket();
//localHost &＃61; InetAddress.getByName("DESKTOP-H5URIFQ");
localHost&＃61;InetAddress.getLocalHost();
String message&＃61;Version&＃43;":"&＃43;id&＃43;":"&＃43;user&＃43;":"&＃43;host&＃43;":"&＃43;IPMSG_SENDMSG&＃43;":"&＃43;msg;
//封装数据报文&＃xff0c;2425是飞秋的端口号
///1version(IPMSG版本):no(消息编号,可以用系统时间):user(发送消息的用户名):host(发送消息的主机名):command(上述Command常量,可以用|组合多个值):msg(消息内容)
byte[] buff&＃61; message.getBytes("gbk");
dp &＃61; 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();
}
}


  }

}