zoukankan      html  css  js  c++  java
  • 使用java网络连通状态自动检测器

    一、需要的环境

    ①jdk8

    ②eclipse2020

    ③依赖的jar包 javax.mail.jar  httpclient-4.3.6.jar

    二、代码

    package com.star.networktest;
    
    import java.io.*;
    import java.net.HttpURLConnection;
    import java.net.URL;
    import java.text.SimpleDateFormat;
    import java.util.*;
    import javax.mail.BodyPart;
    import javax.mail.Message;
    import javax.mail.Multipart;
    import javax.mail.Session;
    import javax.mail.Transport;
    import javax.mail.internet.*;
    import javax.activation.*;
    
    public class Access {
        private String host = ""; // smtp服务器
        private String from = ""; // 发件人地址
        private String to = ""; // 收件人地址
        private String affix = ""; // 附件地址
        private String affixName = ""; // 附件名称
        private String user = ""; // 用户名
        private String pwd = ""; // 密码
        private String subject = ""; // 邮件标题
    
        public static void main(String[] args) throws IOException {
            Thread t=new Thread() {
                public void run() {
                    try {
                        Timer();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                }        };
                t.start();
    
            }
        
        
    
        public static void printlog(String msg) throws IOException {
            Date date = new Date();
            File f = new File("F:/java/workspace/log/log.txt");
            FileOutputStream fop = new FileOutputStream(f,true);
            // 构建FileOutputStream对象,文件不存在会自动新建
    
            OutputStreamWriter writer = new OutputStreamWriter(fop, "UTF-8");
            // 构建OutputStreamWriter对象,参数可以指定编码,默认为操作系统默认编码,windows上是gbk
            
            writer.append(date.toString()+"	");
            writer.append(msg);
            // 写入到缓冲区
            writer.append("
    ");
            // 换行
            // writer.append("English");
            // 刷新缓存冲,写入到文件,如果下面已经没有写入的内容了,直接close也会写入
    
            writer.close();
            // 关闭写入流,同时会把缓冲区内容写入文件,所以上面的注释掉
            fop.close();
            // 关闭输出流,释放系统资源
    
            FileInputStream fip = new FileInputStream(f);
            // 构建FileInputStream对象
    
            InputStreamReader reader = new InputStreamReader(fip, "UTF-8");
            // 构建InputStreamReader对象,编码与写入相同
    
            StringBuffer sb = new StringBuffer();
            while (reader.ready()) {
                sb.append((char) reader.read());
                // 转成char加到StringBuffer对象中
            }
            System.out.println(sb.toString());
            reader.close();
            // 关闭读取流
    
            fip.close();
            // 关闭输入流,释放系统资源
    
        }
        
         public void setAddress(String from, String to, String subject) {
                this.from = from;
                this.to = to;
                this.subject = subject;
            }
    
            public void setAffix(String affix, String affixName) {
                this.affix = affix;
                this.affixName = affixName;
            }
    
            public void send(String host, String user, String pwd) {
                this.host = host;
                this.user = user;
                this.pwd = pwd;
    
                Properties props = new Properties();
    
                // 设置发送邮件的邮件服务器的属性(这里使用网易的smtp服务器)
                props.put("mail.smtp.host", host);
                // 需要经过授权,也就是有户名和密码的校验,这样才能通过验证(一定要有这一条)
                props.put("mail.smtp.auth", "true");
    
                // 用刚刚设置好的props对象构建一个session
                Session session = Session.getDefaultInstance(props);
    
                // 有了这句便可以在发送邮件的过程中在console处显示过程信息,供调试使
                // 用(你可以在控制台(console)上看到发送邮件的过程)
                session.setDebug(true);
    
                // 用session为参数定义消息对象
                MimeMessage message = new MimeMessage(session);
                try {
                    // 加载发件人地址
                    message.setFrom(new InternetAddress(from));
                    // 加载收件人地址
                    message.addRecipient(Message.RecipientType.TO, new InternetAddress(to));
                    // 加载标题
                    message.setSubject(subject);
    
                    // 向multipart对象中添加邮件的各个部分内容,包括文本内容和附件
                    Multipart multipart = new MimeMultipart();
    
                    // 设置邮件的文本内容
                    BodyPart contentPart = new MimeBodyPart();
                    contentPart.setText("当前网址https://idp.tjut.edu.cn/idp/shibboleth 不能访问,请尽快修复");
                    multipart.addBodyPart(contentPart);
                    // 添加附件
                    BodyPart messageBodyPart = new MimeBodyPart();
                    DataSource source = new FileDataSource(affix);
                    // 添加附件的内容
                    messageBodyPart.setDataHandler(new DataHandler(source));
                    // 添加附件的标题
                    // 这里很重要,通过下面的Base64编码的转换可以保证你的中文附件标题名在发送时不会变成乱码
                    // 报错参考https://jingyan.baidu.com/article/e73e26c0a2617a24adb6a7d4.html
                    sun.misc.BASE64Encoder enc = new sun.misc.BASE64Encoder();
                    messageBodyPart.setFileName("=?GBK?B?"
                            + enc.encode(affixName.getBytes()) + "?=");
                    multipart.addBodyPart(messageBodyPart);
    
                    // 将multipart对象放到message中
                    message.setContent(multipart);
                    // 保存邮件
                    message.saveChanges();
                    // 发送邮件
                    Transport transport = session.getTransport("smtp");
                    // 连接服务器的邮箱
                    transport.connect(host, user, pwd);
                    // 把邮件发送出去
                    transport.sendMessage(message, message.getAllRecipients());
                    transport.close();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            
    //        实现定时器
           public static void Timer() throws IOException {
              while(true) {
                  try {
                      Thread.sleep(59000);
                      SimpleDateFormat d =new SimpleDateFormat("mm");
    //                  if(d.format(new Date()).equals("01")) {
                          if(d.format(new Date()).equals("24")) {
                            StringBuffer error = new StringBuffer();
    
                            long begintime = System.currentTimeMillis();
                            try {
                    // PKIX path building failed  自己的Java环境没有相关网站的证书  去网站下载证书导入到自己的java环境    
                                URL url = new URL("https://idp.tjut.edu.cn/idp/shibboleth");
    
                                HttpURLConnection urlcon = (HttpURLConnection) url.openConnection();
                                urlcon.connect(); // 获取连接
                                
                                InputStream is = urlcon.getInputStream();
                                System.out.println(urlcon.getResponseCode()); // 获取连接状态码
                                System.out.println(urlcon.getResponseMessage()); // 获取HTTP响应消息
                                printlog("访问正常");
                            } catch (IOException e) {
                                System.out.println(e);
                                Access cn = new Access();
                                // 设置发件人地址、收件人地址和邮件标题
                                cn.setAddress("发送者@tom.com", "接受者1@qq.com", "网络连通状态检测报告");
                                // 设置要发送附件的位置和标题
                                cn.setAffix("F:/java/workspace/log/log.txt", "log.txt");
                                cn.send("smtp.tom.com", "发送者@tom.com", "****");
                                
                                cn.setAddress("starzhai@tom.com", "接收者2@qq.com", "网络连通状态检测报告");
                                // 设置要发送附件的位置和标题
                                cn.setAffix("F:/java/workspace/log/log.txt", "log.txt");
                                cn.send("smtp.tom.com", "发送者@tom.com", "******");
                                printlog("访问异常,已将报告发送至邮箱");
                            }
                      }
                  } catch (InterruptedException e) {
                      e.printStackTrace();
                  }
              }
           }
    
    }
  • 相关阅读:
    用友U8远程接入客户端提示启动客户端错误
    oracle 10g 错误 ORA-01653 的解决过程
    用友 凭证引入 如何删除引入的外部凭证
    Delphi实现程序只运行一次并激活已打开的程序
    Delphi Raize的日期控件RzDateTimeEdit星期几不能正确显示的问题
    U8 提示“操作员没有查询权限或视图权限”
    数据库图片存储也读取
    Delph最简单i获取外网IP
    cxgrid 单元格合并
    cocos2d 中使用 pickerView 简单的老虎机应用
  • 原文地址:https://www.cnblogs.com/StarZhai/p/13666652.html
Copyright © 2011-2022 走看看