笔记之_Java整理socket

Posted 2020-10-15 莫轩ASL

Java中取得当前项目的根目录：
    TestPath.class.getResoure(“/template.html”).getPath();
TestPath.class.getResoure(“/template.html”).getFile();
UDP只能在局域网传输数据，传输到外网需要打洞穿透
打洞：内网到外网的穿透
手机联网：红外线或者无线网
Interrupt()停止线程
Socket：如果要实现实时通讯，必须使用socket网络编程
分类：
    TCP：
    UDP：
计算机硬件有七层网络传输协议
Java实现Socket：
        serverSocket(端口号)：代表服务器
        Socket(服务器Ip,端口号)：代表客户端
Socket分为2大类：
 1)、TCP   传输控制协议
是面向连接的协议安全，可靠的.
也就是说，在收发数据前，必须和对方建立可靠的连接。
一个TCP连接必须要经过三次“对话”才能建立起来，其中的过程非常复杂，只简单的描述下这三次对话的简单过程：
主机A向主机B发出连接请求数据包：“我想给你发数据，可以吗？”，这是第一次对话；
主机B向主机A发送同意连接和要求同步（同步就是两台主机一个在发送，一个在接收，协调工作）的数据包：“可以，你什么时候发？”，这是第二次对话；
主机A再发出一个数据包确认主机B的要求同步：“我现在就发，你接着吧！”，这是第三次对话。三次“对话”的目的是使数据包的发送和接收同步，经过三次“对话”之后，主机A才向主机B正式发送数据
 2)、UDP    用户数据报协议
（1） UDP是一个非连接的协议，传输数据之前源端和终端不建立连接，当它想传送时就简单地去抓取来自应用程序的数据，并尽可能快地把它扔到网络上。在发送端，UDP传送数据的速度仅仅是受应用程序生成数据的速度、计算机的能力和传输带宽的限制；在接收端，UDP把每个消息段放在队列中，应用程序每次从队列中读一个消息段。
（2） 由于传输数据不建立连接，因此也就不需要维护连接状态，包括收发状态等，因此一台服务机可同时向多个客户机传输相同的消息。
（3） UDP信息包的标题很短，只有8个字节，相对于TCP的20个字节信息包的额外开销很小。
（4） 吞吐量不受拥挤控制算法的调节，只受应用软件生成数据的速率、传输带宽、源端和终端主机性能的限制。
（5）UDP使用尽最大努力交付，即不保证可靠交付，因此主机不需要维持复杂的链接状态表（这里面有许多参数）。
（6）UDP是面向报文的。发送方的UDP对应用程序交下来的报文，在添加首部后就向下交付给IP层。既不拆分，也不合并，而是保留这些报文的边界，因此，应用程序需要选择合适的报文大小。
我们经常使用“ping”命令来测试两台主机之间TCP/IP通信是否正常，其实“ping”命令的原理就是向对方主机发送UDP数据包，然后对方主机确认收到数据包，如果数据包是否到达的消息及时反馈回来，那么网络就是通的。

TCP服务器端代码示例：
public class Server {
    private static ServerSocket server=null;
    private static PrintWriter out=null;
    private static BufferedReader  reader=null;
    private static Map<String,Socket> userMessages=new Hashtable<String, Socket>();
    private static void first(){
        try {
            //服务器启动
            server=new ServerSocket(1888);
            while(true){
                //有客户连接时
                Socket client=server.accept();
                //保存客户端信息，ip、socket
                userMessages.put(client.getInetAddress().getHostAddress(), client);
                //开辟线程处理数据
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            //取得输出流
                            out=new PrintWriter(client.getOutputStream(),true);
                            //取得输入流
                            reader=new BufferedReader(new InputStreamReader(client.getInputStream(),"utf-8"));
                            out.println("欢迎登陆");
                            String message=reader.readLine();
                        } catch (IOException e) {
                            e.printStackTrace();
                        }
                    }
                }).start();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            if(server!=null){
                try {
                    server.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
    }
    public static void main(String[] args) {
        first();
    }
}
TCP客户端代码示例：
public class Client {
    private static Socket client = null;
    private static PrintWriter out = null;
    private static BufferedReader reader = null;
    public static void main(String[] args) {
        try {
            client=new Socket("192.168.1.102",1888);
            out=new PrintWriter(client.getOutputStream().true);
            reader=new    BufferedReader(new InputStreamReader(client.getInputStream()));
            //向服务器发送信息
            out.println("");
            //服务器发送过来的数据保存到变量
            String message=reader.readLine();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}
UDP服务器实例：
public static void main(String[] args) {
        // 1、创建一个服务器 套接字
        DatagramSocket server = null;
        try {
            server = new DatagramSocket(18899);
            // 2、定一个字节 数组来接收数据
            byte[] data = new byte[1024];
            // 3、定义一个数据包对象
            DatagramPacket recePacket = new DatagramPacket(data, data.length);
            // 4、阻塞式的接收
            server.receive(recePacket);
            System.out.println("*************客户端来消息了***********");
            // 5、打印消息
            String msg = new String(recePacket.getData(), 0,
                    recePacket.getLength());
            // 6、向发过来的那个客户端回复点消息
            InetAddress addr = recePacket.getAddress(); // 客户端的IP
            int port = recePacket.getPort(); // 客户端的端口号
            System.out.println(addr.toString()+"-"+port+":客户端发过来的消息是：" + msg);
            // 7、回复 :收到了
            String str = "收到了";
            byte[] buf = str.getBytes();
            // 8、创建一个发送的报文
            DatagramPacket sendPacket = new DatagramPacket(buf, buf.length,
                    addr, port);
            server.send(sendPacket);
        } catch (SocketException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (server != null) {
                server.close();
            }
        }
    }
UDP客户端实例：
public static void main(String[] args) {
        //创建一个客户端 
        DatagramSocket client=null;
        try {
            client=new DatagramSocket();
            //向服务器发送消息
            String str="客户端测试消息!";
            byte[] buf=str.getBytes();
            //3、定义服务器的IP
            InetAddress addr=InetAddress.getByName("192.168.16.171");
            //4、创建一个数据报对象
            DatagramPacket sendPacket=new DatagramPacket(buf, buf.length, addr, 18899);
            //5、发送消息
            client.send(sendPacket);
            //6、客户端等待服务器发送过来的消息
            byte[] data=new byte[1024];
            DatagramPacket recePacket=new DatagramPacket(data, data.length);
            //7、客户阻止式的接收消息
            client.receive(recePacket);
            //8、把消息转换成字符串
            String msg=new String(recePacket.getData(),0,recePacket.getLength()  );
            System.out.println("服务器回复的消息是："+msg);
        } catch (SocketException e) { 
            e.printStackTrace();
        } catch (UnknownHostException e) { 
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }finally{
            if(client!=null){
                client.close();
            }
        }
    }
XML读取文件实例：
    public static void main(String[] args) {
        String xmlPath="c:\\1.xml";
        //1、创建一个SAXReader
        SAXReader  sax=new SAXReader();    
        try {
            //2、读取文件 
            Document document=sax.read(new File(xmlPath));
            //3、取得doucumet文档的根节点 ( document.getElement????)
            Element root= document.getRootElement();
            //4、得到根节点下面的子节点
            List allEntry= root.elements("entry"); 
            //5、循环遍历每一个节点
            for(Object  obj : allEntry){
                Element  ele=(Element) obj;
                System.out.println("编号："+ele.elementTextTrim("id"));
                System.out.println("标题："+ele.elementTextTrim("title"));
                //作者的节点
                Element authorElement=ele.element("author");
                System.out.println("作者："+authorElement.elementTextTrim("name"));
                //取得链接地址的属性
                Element linkElement=ele.element("link");
                String link=linkElement.attributeValue("href");
                System.out.println("连接地址:"+link);
                System.out.println("推荐次数："+ele.elementTextTrim("diggs"));
                System.out.println("浏览次数："+ele.elementTextTrim("views"));
                System.out.println("回复次数："+ele.elementTextTrim("comments"));
                System.out.println("\n--------------------------------------------------------");
            }
        } catch (DocumentException e) { 
            e.printStackTrace();
        }
    }