案例: 模拟登陆,获取Druid SQL监控数据

2024-05-09 17:38

本文主要是介绍案例: 模拟登陆,获取Druid SQL监控数据,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

本文重在编写模拟登陆的代码;Druid SQL监控 admin 平台,重在辅助验证;

本案例采用springboot框架;

1.jar包版本信息:

<!-- alibaba的druid数据库连接池 --><dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.20</version></dependency>

2. 数据库连接池配置信息:

spring:datasource:name: monitortype: com.alibaba.druid.pool.DruidDataSourcedruid:filters: statdriver-class-name: com.mysql.jdbc.Driverurl: jdbc:mysql://IP:PORT/DATABASE?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghaiusername: rootpassword: rootinitial-size: 1min-idle: 1max-active: 20max-wait: 60000time-between-eviction-runs-millis: 60000min-evictable-idle-time-millis: 300000validation-query: SELECT 'x'test-while-idle: truetest-on-borrow: falsetest-on-return: falsepool-prepared-statements: falsemax-pool-prepared-statement-per-connection-size: 20

3.DruidConfiguration配置代码:

import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;/*** <p>类描述</p>** @author yuanyirui* @Date 2020年1月3日 上午10:21:22*/
@Configuration
public class DruidConfiguration {@Beanpublic ServletRegistrationBean statViewServle() {ServletRegistrationBean servletRegistrationBean = new ServletRegistrationBean(new StatViewServlet(), "/druid/*");//IP白名单//servletRegistrationBean.addInitParameter("allow","192.168.1.12,127.0.0.1");//IP黑名单//servletRegistrationBean.addInitParameter("deny","192.168.4.23");//控制台用户servletRegistrationBean.addInitParameter("loginUsername", "admin");servletRegistrationBean.addInitParameter("loginPassword", "admin");//是否能够重置数据servletRegistrationBean.addInitParameter("resetEnable", "false");return servletRegistrationBean;}@Beanpublic FilterRegistrationBean statFilter() {FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean(new WebStatFilter());//添加过滤规则filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
//        filterRegistrationBean.addInitParameter("exclusions","*.js,*.gif,*.jpg,*.png,*.css,*.ico");return filterRegistrationBean;}
}

4.启动项目,登陆地址:

http://localhost:9008/monitor/druid/login.html

如上配置:

用户名和密码同为:admin

 

druid sql API地址:http://localhost:9008/monitor/druid/sql.json

 

5.模拟登陆,后去sql数据

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.httpclient.Cookie;
import org.apache.commons.httpclient.HttpClient;
import org.apache.commons.httpclient.NameValuePair;
import org.apache.commons.httpclient.cookie.CookiePolicy;
import org.apache.commons.httpclient.methods.GetMethod;
import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.params.HttpMethodParams;public class MockDruidLogin {static String druidCookie = "JSESSIONID=3DB050C51ECF84554EE37245DE0CD00A";// 登陆 Urlstatic String loginUrl = "http://localhost:9008/monitor/druid/submitLogin?loginUsername=admin&loginPassword=admin";// 需登陆后访问的 Urlstatic String dataUrl = "http://localhost:9008/monitor/druid/sql.json?orderBy=SQL&orderType=desc&page=1&perPageCount=1000000&";static String headerUrl = "http://localhost:9008/monitor/druid/header.html";public static void main(String[] args) {while (true) {try {login();Thread.sleep(800);} catch (Exception e) {e.printStackTrace();}}
//}private static void login() {try {HttpClient httpClient = new HttpClient();// 模拟登陆,按实际服务器端要求选用 Post 或 Get 请求方式PostMethod postMethod = new PostMethod(loginUrl);// 设置登陆时要求的信息,用户名和密码NameValuePair[] data = {new NameValuePair("loginUsername", "admin"),new NameValuePair("loginPassword", "admin")};postMethod.setParameter("Cookie", druidCookie);postMethod.setRequestBody(data);// 设置 HttpClient 接收 Cookie,用与浏览器一样的策略httpClient.getParams().setCookiePolicy(CookiePolicy.BROWSER_COMPATIBILITY);httpClient.getParams().setParameter(HttpMethodParams.SINGLE_COOKIE_HEADER, true);httpClient.executeMethod(postMethod);//  postMethod.getResponseBody();// 获得登陆后的 CookieCookie[] cookies = httpClient.getState().getCookies();StringBuffer tmpcookies = new StringBuffer();for (Cookie c : cookies) {tmpcookies.append(c.toString() + ";");System.out.println("cookies = " + c.toString());}System.out.println("模拟登录成功");GetMethod getMethod = new GetMethod(dataUrl);getMethod.setRequestHeader("cookie", druidCookie);//核心点是在这里重新设置了cookiepostMethod.setRequestHeader("Referer", headerUrl);postMethod.setRequestHeader("User-Agent", "Mozilla/5.0 (Windows NT 6.1; WOW64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/31.0.1650.63 Safari/537.36");httpClient.executeMethod(getMethod);String text = getMethod.getResponseBodyAsString();
//            System.out.println("获取到SQL返回值: " + text);JSONObject jsonObject = JSONObject.parseObject(text);JSONArray content = jsonObject.getJSONArray("Content");if (content != null&&!content.isEmpty()  ) {for (Object o : content) {JSONObject cont = (JSONObject) o;String sql = cont.getString("SQL");
//                    System.out.println("获取到SQL: " + sql);String pureSql = sql.replaceAll("\\n\\t\\t\\t", " ").replaceAll("\\t", " ").replaceAll("\\n", " ");System.out.println("获取到SQL: " + pureSql.replaceAll("\\?", "1"));}}System.out.println("---------------------------------执行下一个循环---------------------------------");} catch (Exception e) {e.printStackTrace();}}}

 

 

这篇关于案例: 模拟登陆,获取Druid SQL监控数据的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/974052

相关文章

System类获取系统属性

package com.zhong; import java.util.Properties; /**  *   * @author zhong  *  */ public class SystemPropertyTest {          public static void main(String[] args) {         //启动脚本传递参数         if(args

mysql 获得指定数据库所有表名以及指定表的所有字段名

SELECTCOLUMN_NAME 列名,DATA_TYPE 字段类型,COLUMN_COMMENT 字段注释FROMinformation_schema. COLUMNSWHEREtable_name = 'sys_user' ## 表名AND table_schema = 'test'; ## 数据库/*获得指定表的所有字段*/SELECT*FROMinformation_schem

Spring Boot - 使用类类型信息获取所有已加载的bean

Spring启动会在内部加载大量bean,以最少的配置运行您的应用程序。在这个例子中,我们将学习如何找出所有那些Spring boot加载的bean及其类类型信息。 使用ApplicationContext获取所有已加载的bean 要自动执行方法,当应用程序完全加载时,我正在使用CommandLineRunner接口。CommandLineRunner用于指示bean 在Spring应用程序中

mysql:慢查询日志slow_query_log

1、慢查询日志:当查询超过一定的时间没有返回结果的时候,才会记录到慢查询日志中。默认不开启。采样的时候手工开启。可以帮助DBA找出执行慢的SQL语句 2、常用的参数详解: 注意:修改以下参数,需要重新启动数据库服务才会生效。 slow_query_log=off|on     --是否开启慢查询日志slow_query_log_file=filename --指定保存路径及文件名,默认为数据

docker搭建mysql主从配置

1.拉取mysql,这里使用5.7 docker pull mysql:5.7 2、在本地主机新建两个配置文件:my-master.cnf、my-slave.cnf my-master.cnf: [mysqld]log-bin = mysql-binserver-id = 1 my-slave.cnf: [mysqld]server-id = 2 注意:自己创建文件所在的路径。

MyBatis的update语句的返回值改为从匹配数改为受影响的记录数,向mysql连接添加useAffectedRows=true一个参数即可。

1、现象mysql更新update语句执行时,没有内容变更的话,会返回“0”;存在内容更新的话,会返回会返回有内容更新的记录数“1”。  2、mybatis默认情况,没有内容更新也是返回“1”。这么怎么会是”1“,不应该是”0“???其实默认mybatis返回的是 Rows matched “1”,而不是 “ 0 row affected ”中的 “0”。  3、那需要怎么才能让m

MySql删除重复数据只保留最小id的那条数据。某某公司的临时面试题

错误代码: DELETE FROMpayment WHEREserial IN ( SELECT serial FROM payment GROUP BY serial HAVING count(*) > 1 ) AND id NOT IN ( SELECT min( id ) AS id FROM payment GROUP BY serial HAVING count( serial )

mysql升序排序使null结果排最后

1.现象mysql升序排序的null结果排最前面   select * FROM payment ORDER BY serial ASC; -- null值最前面  结果: 2.现象mysql降序序排序的null结果排最后面 select * FROM payment ORDER BY serial DESC; -- NULL 值最后 结果:  3.使mysql升序排序的n

Android_02_获取SD卡的可用容量

代码示例如下: package com.itheima.getsdavail;import java.io.File;import android.os.Build;import android.os.Bundle;import android.os.Environment;import android.os.StatFs;import android.app.Activity;i

在android的同一个wifi局域网下,利用socket与多个手机进行数据的收发

前言: 在这里强调局域网,是因为内网之间的设备通信时,无需经过外网,若想内网的设备能够与外网进行通信,可自行百度其解决办法... 虽说利用wifi,实质是怎么利用socket来进行通信的问题 步骤一:编写服务端和客户端的代码 服务端代码(MainActivity.java): package com.example.dai.wifiserver;import android