客户端
import java.io.*; import java.net.*; public class TalkClient { public static void main(String args[]) { try{ //向本机的4700端口发出客户请求 Socket socket=new Socket("192.168.43.100",8081); //由系统标准输入设备构造BufferedReader对象 BufferedReader sin=new BufferedReader(new InputStreamReader(System.in)); //由Socket对象得到输出流,并构造PrintWriter对象 PrintWriter os=new PrintWriter(socket.getOutputStream()); //由Socket对象得到输入流,并构造相应的BufferedReader对象 BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream())); String readline; readline=sin.readLine(); //从系统标准输入读入一字符串 while(!readline.equals("bye")){//若从标准输入读入的字符串为 "bye"则停止循环 //将从系统标准输入读入的字符串输出到Server os.println(readline); os.flush();//刷新输出流,使Server马上收到该字符串 //在系统标准输出上打印读入的字符串 System.out.println("Client:"+readline); //从Server读入一字符串,并打印到标准输出上 System.out.println("Server:"+is.readLine()); readline=sin.readLine(); //从系统标准输入读入一字符串 } //继续循环 os.close(); //关闭Socket输出流 is.close(); //关闭Socket输入流 socket.close(); //关闭Socket }catch(Exception e) { System.out.println("Error"+e); //出错,则打印出错信息 } } }
服务器端
import java.io.IOException; import java.net.ServerSocket; public class MultiTalkServer { static int clientnum = 0; //静态成员变量,记录当前客户的个数 public static void main(String args[]) throws IOException { ServerSocket serverSocket = null; boolean listening = true; try { //创建一个ServerSocket在端口4700监听客户请求 serverSocket = new ServerSocket(8081); } catch (IOException e) { System.out.println("Could not listen on port:4700."); // System.exit(-1); //退出 } while (listening) { //循环监听 //监听到客户请求,根据得到的Socket对象和客户计数创建并启动服务线程 new ServerThread(serverSocket.accept(), clientnum).start(); clientnum++; //增加客户计数 } serverSocket.close(); //关闭ServerSocket } }
多线程
import java.io.*; import java.net.*; public class ServerThread extends Thread{ Socket socket=null; //保存与本线程相关的Socket对象 int clientnum; //保存本进程的客户计数 public ServerThread(Socket socket,int num) { //构造函数 this.socket=socket; //初始化socket变量 clientnum=num+1; //初始化clientnum变量 } public void run() { //线程主体 try{ String line; //由Socket对象得到输入流,并构造相应的BufferedReader对象 BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream())); //由Socket对象得到输出流,并构造PrintWriter对象 PrintWriter os=new PrintWriter(socket.getOutputStream()); //由系统标准输入设备构造BufferedReader对象 BufferedReader sin=new BufferedReader(new InputStreamReader(System.in)); //在标准输出上打印从客户端读入的字符串 System.out.println("Client "+ clientnum + ":" + is.readLine()); //从标准输入读入一字符串 line=sin.readLine(); while(!line.equals("bye")){//如果该字符串为 "bye",则停止循环 os.println(line);//向客户端输出该字符串 os.flush();//刷新输出流,使Client马上收到该字符串 //在系统标准输出上打印该字符串 System.out.println("Server:"+line); //从Client读入一字符串,并打印到标准输出上 System.out.println("Client:"+ clientnum +is.readLine()); line=sin.readLine();//从系统标准输入读入一字符串 }//继续循环 os.close(); //关闭Socket输出流 is.close(); //关闭Socket输入流 socket.close(); //关闭Socket }catch(Exception e){ System.out.println("Error:"+e);//出错,打印出错信息 } } }
客户端
import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.io.BufferedReader; import java.io.InputStreamReader; public class QuoteClient { public static void main(String[] args) throws IOException { if (args.length != 1) { // 如果启动时没有给出Server的名字,那么输出错误信息并退出 System.out.println("Usage:java QuoteClient <hostname>"); return; } DatagramSocket socket = new DatagramSocket();// 建立数据报套接字 byte[] buf = new byte[256]; // 建立缓冲区 // 由命令行给出的第一个参数默认为Server的域名,通过它得到Server的IP信息 InetAddress address = InetAddress.getByName(args[0]); // 创建DatagramPacket对象 DatagramPacket packet = new DatagramPacket(buf, buf.length, address, 4445); socket.send(packet); // 发送 // 创建新的DatagramPacket对象,用来接收数据报 packet = new DatagramPacket(buf, buf.length); socket.receive(packet); // 接收 // 根据接收的字节数组生成相应的字符串 String received = new String(packet.getData()); // 输出生成的字符串 System.out.println("Quote of the Moment:" + received); socket.close(); // 关闭数据套接字 DatagramSocket socket=new DatagramSocket();//创建数据报套接字 BufferedReader sin = new BufferedReader(new InputStreamReader(System.in)); String readLine; InetAddress address=InetAddress.getByName("127.0.0.1");//Server的IP信息 while(!(readLine = sin.readLine()).equals("bye")) { byte[] buf = readLine.getBytes(); //创建DatagramPacket对象 DatagramPacket packet=new DatagramPacket(buf, buf.length, address, 4445); socket.send(packet); //发送 buf = new byte[256]; //创建新的DatagramPacket对象,用来接收数据报 packet=new DatagramPacket(buf,buf.length); socket.receive(packet); //接收 buf = packet.getData(); //根据接收到的字节数组生成相应的字符串 String received=new String(buf); //打印生成的字符串 System.out.println("Quote of the Sever: "+received ); } socket.close(); //关闭套接口 } }
服务器端
public class QuoteServer { public static void main(String args[])throws java.io.IOException{ new QuoteServerThread().start();// 启动一个QuoteServerThread线程 } }
多线程
import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; public class QuoteServerThread extends Thread// 服务器线程 { protected DatagramSocket socket = null;// DatagramSocket protected BufferedReader in = null;// Reader protected boolean moreQuotes = true;// 标志变量。是否继续操作 public QuoteServerThread() throws IOException {// this("QuoteServerThread");// QuoteServerThread } public QuoteServerThread(String name) throws IOException { super(name); // socket = new DatagramSocket(4445);// 创建数据报套接字端口4445 in = new BufferedReader(new InputStreamReader(System.in)); } public void run() // 线程主体 { while (moreQuotes) { try { byte[] buf = new byte[256]; // 创建缓冲区 DatagramPacket packet = new DatagramPacket(buf, buf.length); // 由缓冲区构建DatagramPacket对象 socket.receive(packet); // 接收数据报 // 输出客户端发送的内容 System.out.println(new String(packet.getData())); // 从屏幕获取输入内容,作为发送给客户端的内容 String dString = in.readLine(); // 如果是bey,则向客户端发完消息后退出 if (dString.equals("bye")) { moreQuotes = false; } buf = dString.getBytes();// 把String转换成字节数组,以便传送 // 从Client端传来的Packet中得到Client地址 InetAddress address = packet.getAddress(); int port = packet.getPort(); // 端口号 // 根据客户端信息构建DatagramPacket packet = new DatagramPacket(buf, buf.length, address, port); socket.send(packet); // 发送数据报 } catch (IOException e) { // 异常处理 e.printStackTrace(); // 输出异常栈信息 moreQuotes = false; // 标志变量置false,以结束循环 } } socket.close(); // 关闭数据报套接字 } }
TCP(Transmission ControlProtocol,传输控制协议)是面向连接的协议,也就是说,在收发数据前,必须和对方建立可靠的连接。一个TCP连接必须要经过三次“对话”才能建立起来,其中的过程非常复杂。
UDP(User Data Protocol,用户数据报协议)是一个非连接的协议,传输数据之前源端和终端不建立连接,当它想传送时就简单地去抓取来自应用程序的数据,并尽可能快地把它扔到网络上。
TCP与UDP的区别:
1.基于连接与无连接;
2.对系统资源的要求(TCP较多,UDP少);
3.UDP程序结构较简单;
4.流模式与数据报模式 ;
5.TCP保证数据正确性,UDP可能丢包,TCP保证数据顺序,UDP不保证。
TCP中Java提供了 Socket
类 与 ServerSocket
类
UDP中Java提供了DatagramSocket
类 与 DatagramPacket
类
1、物理层(Physical Layer)在局部局域网上传送数据框(frame),它负责管理电脑通信设备和网络媒体之间的互通。
2、数据链路层(Data Link Layer)负责网络寻址、错误侦测和改错。当表头和表尾被加至数据包时,会形成帧。数据链表头(DLH)是包含了物理地址和错误侦测及改错的方法。
3、网络层(Network Layer)决定数据的路径选择和转寄,将网络表头(NH)加至数据包,以形成分组。
4、传输层(Transport Layer)把传输表头(TH)加至数据以形成数据包。
5、会话层(Session Layer)负责在数据传输中设置和维护电脑网络中两台电脑之间的通信连接。
6、表示层(Presentation Layer)把数据转换为能与接收者的系统格式兼容并适合传输的格式。
7、应用层(Application Layer)提供为应用软件而设的界面,以设置与另一应用软件之间的通信。
1、连接方面
TCP面向连接(如打电话要先拨号建立连接)。
UDP是无连接的,即发送数据之前不需要建立连接。
2、安全方面
TCP提供可靠的服务,通过TCP连接传送的数据,无差错,不丢失,不重复,且按序到达。
UDP尽最大努力交付,即不保证可靠交付。
3、传输效率
TCP传输效率相对较低。
UDP传输效率高,适用于对高速传输和实时性有较高的通信或广播通信。
4、连接对象数量
TCP连接只能是点到点、一对一的。
UDP支持一对一,一对多,多对一和多对多的交互通信。
因为通过TCP连接传送的数据,无差错,不丢失,不重复,且按序到达。
传输层。
高层次网络编程适用于面向Internet的通信,而低层次网络编程则面向内部网络通信。
Socket:在创建新的socket对象时
数据报:在DatagramPacket的构造方法中
public class Homepage { public static void main(String[] args) throws IOException { URL url= new URL("http://www.hzau.edu.cn/"); URLConnection con = url.openConnection(); BufferedReader is = new BufferedReader(new InputStreamReader(con.getInputStream(), "UTF-8")); FileOutputStream fos = new FileOutputStream("/Users/Desktop/hzau.html");//指定路径,它会自动新建一个文件 String line; while((line=is.readLine()) != null) { line = line + "\n"; fos.write(line.getBytes("UTF-8")); fos.flush(); } System.out.println("Successful!"); is.close(); fos.close(); } }