国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

Java 實現 Ping 命令

lastSeries / 2794人閱讀

摘要:是和系統下的一個命令。也屬于一個通信協議,是協議的一部分。利用命令可以檢查網絡是否連通。百度百科上關于的介紹寫的還不錯,可以參考。做這個是因為我們需要用程序下載一些資源,先提前簡單判斷一下是否可連通,有需要的隨便拿去。

Ping是Windows、Unix和Linux系統下的一個命令。Ping也屬于一個通信協議,是TCP/IP協議的一部分。利用 ping 命令可以檢查網絡是否連通。

百度百科上關于 Ping 的介紹寫的還不錯,可以參考。

嘗試用Java 寫了個簡易的實現,代碼如下:

package com.coder4j.main;

import java.io.IOException;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.regex.Pattern;

/**
 * Java 實現的簡易Ping 工具
 * 
 * @author Chinaxiang
 * @date 2015-08-11
 *
 */
public class JavaPing {

    private static int port = 80;

    /**
     * 內部Target 類,一個實例代表一個Socket 連接
     */
    private static class Target {
        private InetSocketAddress address;
        private SocketChannel channel;
        private Exception failure;
        private long connectStart;
        private long connectFinish = 0;
        private boolean shown = false;

        public Target(String host) {
            try {
                address = new InetSocketAddress(InetAddress.getByName(host), port);
            } catch (IOException x) {
                failure = x;
            }
        }

        public void show() {
            String result;
            if (connectFinish != 0) {
                result = Long.toString(connectFinish - connectStart) + "ms";
            } else if (failure != null) {
                result = failure.toString();
            } else {
                result = "Timed out";
            }
            System.out.println(address + " : " + result);
            shown = true;
        }
    }

    /**
     * 內部Printer 類,繼承自Thread ,實現對Target實例show方法的調用
     */
    private static class Printer extends Thread {
        private LinkedList pending = new LinkedList();

        public Printer() {
            setName("Printer");
            setDaemon(true);
        }

        public void add(Target t) {
            synchronized (pending) {
                pending.add(t);
                pending.notify();
            }
        }

        public void run() {
            try {
                for (;;) {
                    Target t = null;
                    synchronized (pending) {
                        while (pending.size() == 0) {
                            pending.wait();
                        }
                        t = pending.removeFirst();
                    }
                    t.show();
                }
            } catch (InterruptedException x) {
                return;
            }
        }
    }

    /**
     * 內部Connector 類,繼承自Thread ,實現對Target 列表的Ping 測試
     */
    private static class Connector extends Thread {
        private Selector sel;
        private Printer printer;
        private LinkedList pending = new LinkedList();

        public Connector(Printer pr) throws IOException {
            printer = pr;
            sel = Selector.open();
            setName("Connector");
        }

        public void add(Target t) {
            SocketChannel sc = null;
            try {
                sc = SocketChannel.open();
                sc.configureBlocking(false);
                boolean connected = sc.connect(t.address);
                t.channel = sc;
                t.connectStart = System.currentTimeMillis();
                if (connected) {
                    t.connectFinish = t.connectStart;
                    sc.close();
                    printer.add(t);
                } else {
                    synchronized (pending) {
                        pending.add(t);
                    }
                    sel.wakeup();
                }
            } catch (IOException x) {
                if (sc != null) {
                    try {
                        sc.close();
                    } catch (IOException xx) {
                    }
                }
                t.failure = x;
                printer.add(t);
            }
        }

        private void processPendingTargets() throws IOException {
            synchronized (pending) {
                while (pending.size() > 0) {
                    Target t = pending.removeFirst();
                    try {
                        t.channel.register(sel, SelectionKey.OP_CONNECT, t);
                    } catch (IOException x) {
                        t.channel.close();
                        t.failure = x;
                        printer.add(t);
                    }
                }
            }
        }

        private void processSelectedKeys() throws IOException {
            for (Iterator i = sel.selectedKeys().iterator(); i.hasNext();) {
                SelectionKey sk = i.next();
                i.remove();
                Target t = (Target) sk.attachment();
                SocketChannel sc = (SocketChannel) sk.channel();
                try {
                    if (sc.finishConnect()) {
                        sk.cancel();
                        t.connectFinish = System.currentTimeMillis();
                        sc.close();
                        printer.add(t);
                    }
                } catch (IOException x) {
                    sc.close();
                    t.failure = x;
                    printer.add(t);
                }
            }
        }

        volatile boolean shutdown = false;

        public void shutdown() {
            shutdown = true;
            sel.wakeup();
        }

        public void run() {
            for (;;) {
                try {
                    int n = sel.select();
                    if (n > 0)
                        processSelectedKeys();
                    processPendingTargets();
                    if (shutdown) {
                        sel.close();
                        return;
                    }
                } catch (IOException x) {
                    x.printStackTrace();
                }
            }
        }
    }

    /**
     * 提供對外的ping 方法,調用示例:
* JavaPing.ping(new String[]{"www.baidu.com"});
* JavaPing.ping(new String[]{"80", "www.baidu.com"});
* JavaPing.ping(new String[]{"80", "www.baidu.com", "www.cctv.com"}); * * @param args * @throws IOException * @throws InterruptedException */ public static void ping(String[] args) throws IOException, InterruptedException { if (args.length < 1) { System.err.println("Usage: [port] host..."); return; } int firstArg = 0; if (Pattern.matches("[0-9]+", args[0])) { port = Integer.parseInt(args[0]); firstArg = 1; } Printer printer = new Printer(); printer.start(); Connector connector = new Connector(printer); connector.start(); LinkedList targets = new LinkedList(); for (int i = firstArg; i < args.length; i++) { Target t = new Target(args[i]); targets.add(t); connector.add(t); } Thread.sleep(2000); connector.shutdown(); connector.join(); for (Iterator i = targets.iterator(); i.hasNext();) { Target t = i.next(); if (!t.shown) { t.show(); } } } /** * 非常簡易的ping方法,僅僅為了判斷是否可連通。 * * @param host * @param port * @return */ public static boolean ping(String host, int port) { InetSocketAddress address = null; try { address = new InetSocketAddress(InetAddress.getByName(host), port); return !address.isUnresolved(); } catch (IOException e) { return false; } } public static void main(String[] args) throws InterruptedException, IOException { String[] arg = { "80", "www.baidu.com", "127.0.0.1", "www.cctv.com" }; JavaPing.ping(arg); // /127.0.0.1:80 : 2ms // www.baidu.com/61.135.169.121:80 : 5ms // www.cctv.com/220.194.200.232:80 : 14ms boolean result = JavaPing.ping("www.baidu.com", 80); System.out.println(result);// true } }

做這個是因為我們需要用程序下載一些資源,先提前簡單判斷一下是否可連通,有需要的隨便拿去。

文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。

轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/65429.html

相關文章

  • 開源一個監控數據采集Agent:OpenFalcon-SuitAgent

    摘要:目前此系統僅支持類系統下使用,不支持系統什么是這是一個獲取各種系統的監控數據的。監控數據上報公有的跟官方社區的思想一致采集的系統監控信息如內存等等一百多種沒有任何信息其他的業務系統的監控都會打上。 OpenFalcon-SuitAgent 項目地址:github 版本說明 本系統版本劃分如下 alpha:內部測試版(不建議使用于生產環境) beta:公開測試版(不建議使用于生產環境)...

    linkin 評論0 收藏0
  • 開源一個監控數據采集Agent:OpenFalcon-SuitAgent

    摘要:目前此系統僅支持類系統下使用,不支持系統什么是這是一個獲取各種系統的監控數據的。監控數據上報公有的跟官方社區的思想一致采集的系統監控信息如內存等等一百多種沒有任何信息其他的業務系統的監控都會打上。 OpenFalcon-SuitAgent 項目地址:github 版本說明 本系統版本劃分如下 alpha:內部測試版(不建議使用于生產環境) beta:公開測試版(不建議使用于生產環境)...

    王晗 評論0 收藏0

發表評論

0條評論

lastSeries

|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<