目录
- 日志封装类-MyLog
- 线程封装类-LocalThreadPools
- 自定义进度条-LoadProgressbar
- 解压缩类-ZipUtils
- 本地数据库类-mysqliteHelper
- 访问webservice封装-HttpUtils
- Toolbar封装类-MaterialToolbar
- 网络请求框架-OkGo
- 网络请求框架-OkHttp
日志封装类-MyLog
是对android log的封装,封装后 可以设置显示级别
/** * Log的封装类,方便开启和关闭log */ public class MyLog { public static final int VERBOSE = 1; public static final int DEBUG = 2; public static final int INFO = 3; public static final int WARN = 4; public static final int ERROR = 5; public static final int NOTHING = 6; public static final int level = VERBOSE; //设置显示级别 public static final String MYLOG_PATH_SDCARD_DIR = "/sdcard/ScanZbar/log";// 日志文件在sdcard中的路径 public static final String MY_LOG_FILE_NAME = "Log.txt";// 本类输出的日志文件名称 public static void v(String tag, String msg){ if(level <= VERBOSE) Log.v(tag,msg); } public static void d(String tag, String msg){ if(level <= DEBUG) Log.d(tag,msg); } public static void i(String tag, String msg){ if(level <= INFO) Log.i(tag,msg); } public static void w(String tag, String msg){ if(level <= WARN) Log.w(tag,msg); } public static void e(String tag, String msg){ if(level <= ERROR) Log.e(tag,msg); } //调用该方法,可以将日志写入日志文件 public static void Loge(String tag, String msg){ if(LEVEL <= ERROR) { Log.e(tag, msg); writeLogtoFile("ERROR",tag,msg); } } /** * 打开日志文件并写入日志 * @param mylogtype * @param tag * @param text */ private static void writeLogtoFile(String mylogtype, String tag, String text) {// 新建或打开日志文件 Date nowtime = new Date(); String needwriteFiel = new SimpleDateFormat(TimeUtil.SDF3).format(nowtime); String needWriteMessage = new SimpleDateFormat(TimeUtil.SDF1).format(nowtime) + " " + mylogtype + " " + tag + " " + text; File dirPath = Environment.getExternalStorageDirectory(); File dirsFile = new File(MYLOG_PATH_SDCARD_DIR); if (!dirsFile.exists()){ dirsFile.mkdirs(); } //创建日志文件 File file = new File(dirsFile.toString(), needWriteFiel +".txt");// MYLOG_PATH_SDCARD_DIR if (!file.exists()) { try { //在指定的文件夹中创建文件 boolean creatB = file.createNewFile(); if(!creatB) MyLog.e("mylog","创建日志文件失败!"); } catch (Exception e) { e.printStackTrace(); } } try(FileWriter filerWriter = new FileWriter(file, true);// 后面这个参数代表是不是要接上文件中原来的数据,不进行覆盖 BufferedWriter bufWriter = new BufferedWriter(filerWriter)) { bufWriter.write(needWriteMessage); bufWriter.newLine(); } catch (IOException e) { e.printStackTrace(); } } }
使用使用和正常log使用一样
MyLog.e("mylog","123"); MyLog.i("mylog","222"); ...
线程封装类-LocalThreadPools
针对AsyncTask被弃用的替代
/** * @Description TODO(全局使用的线程池) */ public class LocalThreadPools { private static int threadNum = 0; private static String TAG = LocalThreadPools.class.getSimpleName(); private static ExecutorService THREAD_POOL_EXECUTOR; /** * CPU数量 */ private static final int CPU_COUNT = Runtime.getRuntime().availableProcessors(); /** * 线程池数量 */ private static final int CORE_POOL_SIZE = Math.max(2, Math.min(CPU_COUNT-1,4)); /** * 最大线程数量 = CPU数量*2+1 */ private static final int MAXIMUM_POOL_SIZE = CPU_COUNT * 2+1; /** * 等待线程存活时间 */ private static final int KEEP_ALIVE_SECONDS = 60; /** * 等待线程存活时间的单位 */ private static final TimeUnit unit = TimeUnit.MINUTES; private static final blockingQueue<Runnable> sPoolWorkQueue = new LinkedBlockingQueue<>(8); /** * 线程工厂 */ private static final ThreadFactory sThreadFactory = new ThreadFactory() { private final AtomicInteger mCount = new AtomicInteger(1); public Thread newThread(Runnable r) { threadNum++; MyLog.e("mylog","线程工厂创建一个线程:"+threadNum+","+mCount.getAndIncrement()); return new Thread(r, "MangoTask #" + mCount.getAndIncrement()); } }; private void initThreadPool() { MyLog.e("mylog","core_pool_size:"+CORE_POOL_SIZE+",maximum_pool_size:"+MAXIMUM_POOL_SIZE+"," + "KEEP_ALIVE_SECONDS:"+KEEP_ALIVE_SECONDS+","); ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor( CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, KEEP_ALIVE_SECONDS, unit, sPoolWorkQueue, sThreadFactory,new RejectedHandler()){ @Override public void execute(Runnable command) { super.execute(command); MyLog.e("mylog","-----------ActiveCount="+getActiveCount()); MyLog.e("mylog","-----------PoolSize="+getPoolSize()); MyLog.e("mylog","-----------Queue="+getQueue().size()); MyLog.e("mylog","-----------finish="+getCompletedTaskCount()); } }; //允许核心线程空闲超时时被回收 threadPoolExecutor.allowCoreThreadTimeOut(true); THREAD_POOL_EXECUTOR = threadPoolExecutor; } private class RejectedHandler implements RejectedExecutionHandler { @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { //可在这里做一些提示用户的操作 Tools.showToast(mContext.get(),"当前执行的任务过多,请稍后再试"); } } private WeakReference<Context> mContext; private static LocalThreadPools instance; private LocalThreadPools(Context context){ mContext = new WeakReference<>(context); initThreadPool(); } public static LocalThreadPools getInstance(Context context){ if (instance == null) { instance = new LocalThreadPools(context); } return instance; } public void execute(Runnable command){ THREAD_POOL_EXECUTOR.execute(command); } /** * 通过interrupt方法尝试停止正在执行的任务,但是不保证真的终止正在执行的任务 * 停止队列中处于等待的任务的执行 * 不再接收新的任务 * @return 等待执行的任务列表 */ public static List<Runnable> shutdownNow(){ return THREAD_POOL_EXECUTOR.shutdownNow(); } /** * 停止队列中处于等待的任务 * 不再接收新的任务 * 已经执行的任务会继续执行 * 如果任务已经执行完了没有必要再调用这个方法 */ public void shutDown(){ THREAD_POOL_EXECUTOR.shutdown(); sPoolWorkQueue.clear(); } }
使用
LocalThreadPools.getInstance((TestActivity) mView).execute(new Runnable() { @Override public void run() { //异步操作 } });
自定义进度条-LoadProgressbar
自定义进度条
/** * 进度条 */ public class DownLoadProgressbar extends View { private Paint paint = new Paint(); // 绘制背景灰色线条画笔 private Paint paintText = new Paint(); // 绘制下载进度画笔 private float offset = 0f; // 下载偏移量 private float maxvalue = 0f; // 进度的总大小 private float currentValue = 0f; // 当前进度 private Rect mBound = new Rect(); // 获取百分比数字的长宽 private String percentValue = "0%"; // 要显示的现在百分比 private float offsetRight = 0f; // 灰色线条距离右边的距离 private int textSize = SizeUtils.sp2px(25); // 百分比的文字大小 private float offsetTop = SizeUtils.dp2px(18); // 距离顶部的偏移量 public DownLoadProgressbar(Context context) { this(context, null); } public DownLoadProgressbar(Context context, @Nullable AttributeSet attrs) { this(context, attrs, 0); } www.devze.compublic DownLoadProgressbar(Context context, @Nullable AttributeSet attrs, int defStyleAttr) { super(context, attrs, defStyleAttr); getTextWidth(); } @Override protected void onDraw(Canvas canvas) { super.onDraw(canvas); // 绘制底色 paint.setColor(Color.parseColor("#eeeeee")); paint.setStrokeWidth(SizeUtils.dp2px(10)); canvas.drawLine(0, offsetTop, getWidth() - offsetRight, offsetTop, paint); // 绘制进度条颜色 paint.setColor(Color.parseColor("#ff0000")); paint.setStrokeWidth(SizeUtils.dp2px(11)); canvas.drawLine(0, offsetTop, offset, offsetTop, paint); paint.setColor(Color.parseColor("#ffffff")); paint.setStrokeWidth(SizeUtils.dp2px(1)); paintText.setColor(Color.parseColor("#ffffff")); paintText.setTextSize(textSize); paintText.setAntiAlias(true); paintText.getTextBounds(percentValue, 0, percentValue.length(), mBound); canvas.drawLine(offset, offsetTop, offset + mBound.width() + SizeUtils.dp2px(4), offsetTop, paint); canvas.drawText(percentValue, offset, offsetTop + mBound.height() / 2 - SizeUtils.dp2px(2), paintText); } public void setCurrentValue(float currentValue) { this.currentValue = currentValue; int value = (int) (currentValue * 100 / maxvalue); if (value < 100 && value > 0) { percentValue = value + "%"; } else if (value <= 0) { percentValue = "0%"; } else { percentValue = "100%"; } calc(); invalidate(); } private void calc() { if (currentValue < maxvalue) { offset = (getWidth() - offsetRight) * currentValue / maxvalue; } else { offset = getWidth() - offsetRight; } } /** * 设置最大值 * * @param maxValue */ public void setMaxvalue(int maxValue) { this.maxvalue = maxValue; } /** * 获取“100%”的宽度 */ public void getTextWidth() { Paint paint = new Paint(); Rect rect = new Rect(); paint.setTextSize(textSize); paint.setAntiAlias(true); paint.getTextBounds("100%", 0, "100%".length(), rect); offsetRight = rect.width() + SizeUtils.dp2px(5);; } }
解压缩类-ZipUtils
解压缩
/** * 解压缩zip文件 */ public class ZipUtils { public ZipUtils() { } /** * 根据byte数组,生成文件 */ public static void getFile(byte[] bfile, String filePath, String fileName) { BufferedOutputStream bos = null; FileOutputStream fos = null; File file = null; try { File dir = new File(filePath); if (!dir.exists()) {//判断文件目录是否存在 dir.mkdirs(); } file = new File(filePath + fileName); fos = new FileOutputStream(file); bos = new BufferedOutputStream(fos); bos.write(bfile); } catch (Exception e) { e.printStackTrace(); } finally { if (bos != null) { try { bos.close(); } catch (IOException e1) { e1.printStackTrace(); } } if (fos != null) { try { fos.close(); } catch (IOException e1) { e1.printStackTrace(); } } } } // 使用密码解压(图片不加密) public static boolean unZipFile1(String zipFileFullName, String filePath, String password) { try { ZipFile zipFile = new ZipFile(zipFileFullName); // 如果解压需要密码 if (zipFile.isEncrypted()) { zipFile.setPassword(password); } File file = new File(filePath); if (!file.getParentFile().exists()) { file.getParentFile().mkdirs(); } zipFile.extractAll(filePath);//提取所有文件 return true; } catch (Exception e) { e.printStackTrace(); return false; } } // 使用密码解压 public static boolean unZipFile(String zipFileFullName, String filePath, String password) { try { ZipFile zipFile = new ZipFile(zipFileFullName); // 如果解压需要密码 if (zipFile.isEncrypted()) { zipFile.setPassword(password); } File file = new File(filePath); if (!file.getParentFile().exists()) { file.getParentFile().mkdirs(); } zipFile.extractAll(filePath);//提取所有文件 // 压缩 ZipFolder(filePath, filePath + "01"); // 解压 ZipUtils.UnZipFolder(filePath + "01", filePath); return true; } catch (Exception e) { e.printStackTrace(); return false; } } /** * 解压zip到指定的路径 * * @param zipFileString ZIP的名称 * @param outPathString 要解压缩路径 * @throws Exception */ public static void UnZipFolder(String zipFileString, String outPathString) { ZipInputStream inZip = null; OutputStream out = null; try{ inZip = new ZipInputStream(new FileInputStream(zipFileString)); ZipEntry zipEntry; String szName = ""; List<File> fileList = new ArrayList<File>(); while ((zipEntry = inZip.getNextEntry()) != null) { szName = zipEntry.getName(); if (zipEntry.isDirectory()) { //获取部件的文件夹名 szName = szName.substring(0, szName.length() - 1); File folder = new File(outPathString + File.separator + szName); folder.mkdirs(); } else { File file = new File(outPathString + File.separator + szName); if (!file.exists()) { fileList.add(file); file.getParentFile().mkdirs(); file.createNewFile(); } // 获取文件的输出流 // FileOutputStream out = new FileOutputStream(file); out = AesUtil.encrypt(file, AesUtil.toKey(MyApplication.getInstance().getAESKey().getBytes()));// 加密 int len; byte[] buffer = new byte[1024]; // 读取(字节)字节到缓冲区 while ((len = inZip.read(buffer)) != -1) { // 从缓冲区(0)位置写入(字节)字节 out.write(buffer, 0, len); out.flush(); } out.close(); } } inZip.close(); // 删除目录下多余文件夹 File dirFile = new File(outPathString); File[] files = dirFile.listFiles(); for (int i = 0; i < files.length; i++) { if (files[i].isDirectory()) { deleteDirectory(files[i].getAbsolutePath()); } } }catch (Exception e){ e.printStackTrace(); }finally { if(inZip != null){ safeClose(inZip); } if(out != null){ safeClose(out); } } } public static void safeClose(OutputStream fis){ if(fis != null){ try{ fis.close(); }catch (IOException e){ e.printStackTrace(); } } } public static void safeClose(ZipInputStream fis){ if(fis != null){ try{ fis.close(); }catch (IOException e){ e.printStackTrace(); } } } /** * 压缩文件和文件夹 * * @param srcFileString 要压缩的文件或文件夹 * @param zipFileString 解压完成的Zip路径 * @throws Exception */ public static void ZipFolder(String srcFileString, String zipFileString) { FileOutputStream fis = null; ZipOutputStream outZip = null; try{ fis = new FileOutputStream(zipFileString); //创建ZIP outZip = new ZipOutputStream(fis); //创建文件 File file = new File(srcFileString); //压缩 ZipFiles(file.getParent() + File.separator, file.getName(), outZip); //完成和关闭 outZip.finish(); outZip.close(); fis.close(); }catch (Exception e){ e.printStackTrace(); }finally { if(fis != null){ safeClose(fis); } if(outZip != null){ safeClose1(outZip); } } } public static void safeClose(FileOutputStream fis){ if(fis != null){ try { fis.close(); } catch (IOException e) { e.printStackTrace(); } } } public static void safeClose1(ZipOutputStream fis){ if(fis != null){ try { fis.close(); } catch (IOException e) { e.printStackTrace(); } } } /** * 压缩文件 * * @param folderString * @param fileString * @param zipOutputSteam * @throws Exception */ private static void ZipFiles(String folderString, String fileString, ZipOutputStream zipOutputSteam) { FileInputStream inputStream = null; try{ if (zipOutputSteam == null) return; File file = new File(folderString + fileString); if (file.isFile()) { ZipEntry zipEntry = new ZipEntry(fileString); inputStream = new FileInputStream(file); zipOutputSteam.putNextEntry(zipEntry); int len; byte[] buffer = new byte[4096]; while ((len = inputStream.read(buffer)) != -1) { zipOutputSteam.write(buffer, 0, len); } zipOutputSteam.closeEntry(); } else { //文件夹 String fileList[] = file.list(); //没有子文件和压缩 if (fileList.length <= 0) { DCKQNPcrH ZipEntry zipEntry = new ZipEntry(fileString + File.separator); zipOutputSteam.putNextEntry(zipEntry); zipOutputSteam.closeEntry(); } //子文件和递归 for (int i = 0; i < fileList.length; i++) { ZipFiles(folderString + fileString + "/", fileList[i], zipOutputSteam); } } }catch (Exception e){ e.printStackTrace(); }finally { if(inputStream != null){ safeClose(inputStream); } } } public static Bitmap getBitmap(File photoFile) { InputStream fis = null; try { fis = AesUtil.decrypt(photoFile, AesUtil.toKey(MyApplication.getInstance().getAESKey().getBytes())); return BitmapFactory.decodeStream(fis); ///把流转化为Bitmap图片 } catch (FileNotFoundException e) { e.printStackTrace(); MyLog.e("mylog", "e1:" + e.getMessage()); return null; } catch (Exception e) { e.printStackTrace(); MyLog.e("mylog", "e2:" + e.getMessage()); return null; } finally { if(fis != null){ safeClose(fis); } } } public static void safeClose(InputStream fis){ if(fis != null){ try{ fis.close(); }catch (IOException e){ e.printStackTrace(); } } } public static File getPhotoFile(String nonet, String fileAbsolutePath) { File file = new File(fileAbsolutePath); File[] subFile = file.listFiles(); if (subFile != null) { for (int i = 0; i < subFile.length; i++) { // 判断是否为文件夹 /*if (subFile[i].isDirectory()) { getPhotoFile(idNonet, subFile[i].getAbsolutePath()); } else {*/ String filename = subFile[i].getName(); if (!TextUtils.isEmpty(filename) && filename.length() >= 13 && nonet != null) { String subFilename = filename.substring(filename.length() - 13, filename.length() - 4); // MyLog.e("mylog", "subFilename:" + subFilename + " nonet:" + nonet); if (subFilename.equals(nonet)) { MyLog.e("mylog", "filename:" + filename); return subFile[i]; } } } } return null; } /** * @param zipName 压缩文件的路径 * @param filePath 被压缩文件的路径 * @param password 加密 * @description:压缩以及加密 * @author: renbo * @date: 2021年5月19日 下午3:35:33 */ public static void unZipPass(String zipName, String filePath, String password) throws ZipException { ZipFile zipFile = new ZipFile(zipName); ArrayList<File> filesToAdd = new ArrayList<File>(); File root = new File(filePath); File[] files = root.listFiles(); for (File file : files) { if (file.isDirectory()) { filesToAdd.add(new File(file.getAbsolutePath())); } else { filesToAdd.add(new File(file.getAbsolutePath())); } } ZipParameters parameters = new ZipParameters(); parameters.setCompressionMethod(Zip4jConstants.COMP_DEFLATE); // set parameters.setCompressionLevel(Zip4jConstants.DEFLATE_LEVEL_NORMAL); parameters.setEncryptFiles(true); parameters.setEncryptionMethod(Zip4jConstants.ENC_METHOD_AES); parameters.setAesKeyStrength(Zip4jConstants.AES_STRENGTH_256); // Set password parameters.setPassword(password); zipFile.addFiles(filesToAdd, parameters); } /** * 删除单个文件 * * @param filePath 被删除文件的文件名 * @return 文件删除成功返回true,否则返回false */ public static boolean deleteFile(String filePath) { File file = new File(filePath); if (file.isFile() && file.exists()) { return file.delete(); } return false; } /** * 删除文件夹以及目录下的文件 * * @param filePath 被删除目录的文件路径 * @return 目录删除成功返回true,否则返回false */ public static boolean deleteDirectory(String filePath) { boolean flag = false; //如果filePath不以文件分隔符结尾,自动添加文件分隔符 if (!filePath.endsWith(File.separator)) { filePath = filePath + File.separator; } File dirFile = new File(filePath); if (!dirFile.exists() || !dirFile.isDirectory()) { return false; } flag = true; File[] files = dirFile.listFiles(); //遍历删除文件夹下的所有文件(包括子目录) for (int i = 0; i < files.length; i++) { if (files[i].isFile()) { //删除子文件 flag = deleteFile(files[i].getAbsolutePath()); if (!flag) break; } else { //删除子目录 flag = deleteDirectory(files[i].getAbsolutePath()); if (!flag) break; } } if (!flag) return false; //删除当前空目录 return dirFile.delete(); } /** * 根据路径删除指定的目录或文件,无论存在与否 * * @param filePath 要删除的目录或文件 * @return 删除成功返回 true,否则返回 false。 */ public static boolean DeleteFolder(String filePath) { File file = new File(filePath); if (!file.exists()) { return false; } else { if (file.isFile()) { // 为文件时调用删除文件方法 return deleteFile(filePath); } else { // 为目录时调用删除目录方法 return deleteDirectory(filePath); } } } }
本地数据库类-MySQLiteHelper
Android 创建本地数据库
/** * 数据库帮助类 */ public class MySQLiteHelper extends SQLiteOpenHelper { private static String initSqlFile = Environment.getExternalStorageDirectory().getAbsolutePath(); private static String REALPATH = initSqlFile+ File.separator+"XXXX"; //需要创建的路径 private static String REALFILE = REALPATH + File.separator +"xxxx.db"; //需要创建的文件 private static MySQLiteHelper db; private static final int DATEBASE_VERSION = 1; //定义版本号 public static String getRealPath(){ return REALPATH; } public static String getRealFile(){ return REALFILE; } public static void CloseDB(){ db.close(); } //自定义构造方法,简化自动生成的构造方法,path 是主要指定创建db文件的路径 public MySQLiteHelper(Context copythonntext){ this(context,REALFILE,null,DATEBASE_VERSION); MyLog.e("mylog","文件路径:"+REALFILE); } //实现接口必须实现的构造方法 public MySQLiteHelper(Context context, String name, SQLiteDatabase.CursorFactory factory, int version){ super(context, name, factory, version); } @Override public void onCreate(SQLiteDatabase sqLiteDatabase) { //第一次创建数据库时,才会调用 MyLog.e("mylog","创建数据库"); sqLiteDatabase.execSQL(TableA.CREAT_TABLE(TableA.TABLE_NAME())); //创建表 sqLiteDatabase.execSQL(TableB.CREAT_TABLE(TableB.TABLE_NAME())); //创建表 } @Override public void onUpgrade(SQLiteDatabase sqLiteDatabase, int i, int i1) { } }
TableA对于的类
/** * 对应数据表的类 */ public class TableA { public static Stwww.devze.comring TABLE_NAME(){ return "table_a"; } public static final String id = "id"; //ID public static final String s1= "s1";//字段s1 public static final String s1= "s2";//字段s2 public static final String s1= "s3";//字段s3 public static final String s1= "s4";//字段s4 public static final String s1= "s5";//字段s5 public static final String s1= "s6";//字段s6 public static String CREAT_TABLE(String tableName){ return new StringBuffer(). append("CREATE TABLE IF NOT EXISTS ").append(tableName). append("("). append(id).append(" INTEGER PRIMARY KEY AUTOINCREMENT,"). append(s1).append(" TEXT,"). append(s2).append(" TEXT,"). append(s3).append(" TEXT,"). append(s4).append(" TEXT,"). append(s5).append(" TEXT,"). append(s6).append(" TEXT"). append(");").toString(); } }
访问webservice封装-HttpUtils
对访问webservice 接口的请求封装
引入的包
implementation files('libs\\ksoap2-android-assembly-3.3.0-jar-with-dependencies.jar')
代码
import org.ksoap2.serialization.SoapObject; import org.ksoap2.serialization.SoapSerializationEnvelope; import org.ksoap2.transport.HttpTransportSE; import org.XMLpull.v1.XmlPullParserException; import Java.io.IOException; import java.util.Base64; public class HttpUtils { private static final String serviceNameSapce = "http://webservice.cps.xxx.com/"; private static MyApplication myApplication = MyApplication.getInstance(); private HttpUtils() { } // 登录 public static String login(String METHODNAME, String username, String password,String pingid) { SoapObject request = new SoapObject(serviceNameSapce, METHODNAME); request.addProperty("username", jiami(username)); request.addProperty("password", jiami(password)); request.addProperty("pingid",jiami(pingid)); request.addProperty("pingidly",null); return scop(request); } private static String scop(SoapObject request) { //创建SoapSerializationEnvelope 对象,同时指定soap版本号 SoapSerializationEnvelope envelope = new SoapSerializationEnvelope(SoapSerializationEnvelope.VER10); envelope.bodyOut = request;//由于是发送请求,所以是设置bodyOut envelope.dotNet = false;//由于是.net开发的webservice envelope.setOutputSoapObject(request); HttpTransportSE httpTransportSE = new HttpTransportSE(getURl(), 400000); try { httpTransportSE.call(null, envelope);//调用 } catch (IOException e) { e.printStackTrace(); return "{\"error\":\"" + e.getMessage() + "\"}"; } catch (XmlPullParserException e) { e.printStackTrace(); return "{\"error\":\"" + e.getMessage() + "\"}"; } // 获取返回的数据 SoapObject object = (SoapObject) envelope.bodyIn; return object.getProperty(0).toString(); } public static String jiami(String str) { //加密 return AesUtil.aesEncrypt(str, MyApplication.getInstance().getAESKey()); } public static String jiemi(String str){ //解密 return AesUtil.aesDecrypt(str,MyApplication.getInstance().getAESKey()); } public static String getURl(){ return myApplication.getIP()+myApplication.getIP_SUFFIX(); } }
Toolbar封装类-MaterialToolbar
布局文件
<com.google.android.material.appbar.MaterialToolbar android:theme="@style/ThemeOverlay.AppCompat.Dark.ActionBar" android:id="@+id/titlebar" android:background="@color/primary1" app:layout_constraintTop_toTopOf="parent" app:layout_constraintLeft_toLeftOf="parent" app:layout_constraintRight_toRightOf="parent" android:layout_width="match_parent" android:layout_height="wrap_content" app:navigationIcon="@mipmap/back" app:title="XXXX" app:titleTextColor="@color/white" app:titleCentered="true" app:titleTextAppearance="@style/Text18wb" app:subtitle="xxxx年xx月xx日 星期x" app:subtitleTextColor="@color/white" app:subtitleCentered="true" app:subtitleTextAppearance="@style/Text12w" app:menu="@menu/scan_menu"/>
配置文件
1、input_menu.xml
<?xml version="1.0" encoding="utf-8"?> <menu xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto"> <!--showAsAction的值always一直显示,ifRoom如果有地方就显示,没有则隐藏,never一直隐藏--> <item android:id="@+id/owner" android:title="个人中心" android:icon="@mipmap/owner1" app:showAsAction="always"/> </menu>
2、scan_menu.xml
<?xml version="1.0" encoding="utf-8"?> <menu xmlns:android="http://schemas.android.com/apk/res/android" xmlns:app="http://schemas.android.com/apk/res-auto"> <!--showAsAction的值always一直显示,ifRoom如果有地方就显示,没有则隐藏,never一直隐藏--> <item android:id="@+id/clean" android:title="一键清空" android:icon="@mipmap/clean1" app:showAsAction="ifRoom"/> <item android:id="@+id/input" android:title="行李补录" android:icon="@mipmap/shoudong" app:showAsAction="ifRoom"/> <!-- <item--> <!-- android:id="@+id/setting"--> <!-- android:title="Setting"--> <!-- android:icon="@mipmap/ic_launcher"--> <!-- app:showAsAction="never"/>--> </menu>
初始化
private void initToolBar(){ flightInputBinding.titlebar.setTitle("航班设置"); flightInputBinding.titlebar.setSubtitle(myApplication.getDATE_WEEK()); setSupportActionBar(flightInputBinding.titlebar); }
布局与按钮事件
@Override public boolean onCreateOptionsMenu(Menu menu) { getMenuInflater().inflate(R.menu.input_menu, menu); return super.onCreateOptionsMenu(menu); } @Override public boolean onOptionsItemSelected(@NonNull MenuItem item) { int id = item.getItemId(); if(id == android.R.id.home){ Dialog.showFinishDialog(this, "确定要退出APP么?", () -> myApplication.finishAllActivity()); }else if(id == R.id.owner){ Intent i = new Intent(FlightInputActivity.this,InfomationActivity.class); startActivityForResult(i,2001); } return super.onOptionsItemSelected(item); }
网络请求框架-OkGo
引入包
implementation 'com.lzy.net:okgo:3.0.4'
工具类
1、TrustAllCerts
此类用于绕过https验证
package com.kaiya.mvp.npm_ar.utils; import java.security.SecureRandom; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLSession; import javax.net.ssl.SSLSocketFactory; import javax.net.ssl.TrustManager; import javax.net.ssl.X509TrustManager; /** * Created by gang.qin * Date:2024/3/19 15:05 * 质量、速度、廉价,选择其中两个 --- 匿名 */ //public class TrustAllCerts implements X509TrustManager { // @Override // public void checkClientTrusted(X509Certificate[] chain, String authType) {} // // @Override // public void checkServerTrusted(X509Certificate[] chain, String authType) {} // // @Override // public X509Certificate[] getAcceptedIssuers() {return new X509Certificate[0];} //} public class TrustAllCerts implements X509TrustManager { @Override public void checkClientTrusted(X509Certificate[] chain, String authType) throws CertificateException { } @Override public void checkServerTrusted(X509Certificate[] chain, String authType) throws CertificateException { if (chain == null) { throw new IllegalArgumentException(" Check Server x509Certificates is null"); } } @Override public X509Certificate[] getAcceptedIssuers() { return new X509Certificate[0]; } public static SSLSocketFactory createSSLSocketFactory() { SSLSocketFactory ssfFactory = null; try { SSLContext sc = SSLContext.getInstance("TLS"); sc.init(null, new TrustManager[]{new TrustAllCerts()}, new SecureRandom()); ssfFactory = sc.getSocketFactory(); } catch (Exception e) { } return ssfFactory; } public static class TrustAllHostnameVerifier implements HostnameVerifier { @Override public boolean verify(String hostname, SSLSession session) { return true; } } }
2、封装
package com.kaiya.mvp.npm_ar.utils; import android.app.Application; import android.content.Context; import android.transition.TransitionManager; import com.lzy.okgo.OkGo; import com.lzy.okgo.cookie.CookieJarImpl; import com.lzy.okgo.cookie.store.MemoryCookieStore; import com.lzy.okgo.interceptor.HttpLoggingInterceptor; import java.security.KeyManagementException; import java.security.NoSuchAlgorithmException; import java.security.SecureRandom; import java.security.cert.CertificateException; import java.security.cert.X509Certificate; import java.util.concurrent.TimeUnit; import java.util.logging.Level; import javax.net.ssl.HostnameVerifier; import javax.net.ssl.SSLContext; import javax.net.ssl.SSLSession; import javax.net.ssl.TrustManager; import javax.net.ssl.X509TrustManager; import okhttp3.OkHttpClient; /** * Created by gang.qin * Date:2024/3/20 15:41 * 质量、速度、廉价,选择其中两个 --- 匿名 */ public class OkGoUtils { public static X509TrustManager xtm; public static SSLContext sslContext; public static void initOkGo(Application application){ xtm = new X509TrustManager() { @Override public void checkClientTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException { } @Override public void checkServerTrusted(X509Certificate[] x509Certificates, String s) throws CertificateException { } @Override public X509Certificate[] getAcceptedIssuers() { return new X509Certificate[0]; } }; try { sslContext = SSLContext.getInstance("SSL"); sslContext.init(null, new TrustManager[]{xtm}, new SecureRandom()); } catch (NoSuchAlgorithmException e) { e.printStackTrace(); } catch (KeyManagementException e) { e.printStackTrace(); } HostnameVerifier DO_NOT_VERIFY = (hostname, session) -> true; // OkGo.getInstance().init(this); //最简单的配置 什么都不需要写 全部使用默认参数 OkHttpClient.Builder builder = new OkHttpClient.Builder(); //可以使用OkGo内置的log拦截器打印log,如果你觉得不好用,也可以自己写个,这个没有限制。 HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor("OkGo"); //log打印级别 loggingInterceptor.setPrintLevel(HttpLoggingInterceptor.Level.BODY); //log颜色级别 loggingInterceptor.setColorLevel(Level.ALL); builder.addInterceptor(loggingInterceptor); //全局的读取超时时间 builder.readTimeout(OkGo.DEFAULT_MILLISECONDS, TimeUnit.MILLISECONDS); //全局的写入超时时间 builder.writeTimeout(OkGo.DEFAULT_MILLISECONDS, TimeUnit.MILLISECONDS); //全局的连接超时时间 builder.connectTimeout(OkGo.DEFAULT_MILLISECONDS, TimeUnit.MILLISECONDS); /* * connectTimeout:指客户端和服务器 建立通道 的时间 writeTimeout:客户端把数据写出去需要的时间 readTimeout:客户端等待服务器返回数据的时间 * */ //使用内存保持cookie,app退出后,cookie消失 builder.cookieJar(new CookieJarImpl(new MemoryCookieStore())); if(sslContext != null){ builder.sslSocketFactory(sslContext.getSocketFactory(),xtm) .hostnameVerifier(DO_NOT_VERIFY) .build(); }else{ MyLog.e("mylog","过滤器出错!"); } OkGo.getInstance().init(application)//必须调用初始化 .setOkHttpClient(builder.build()) //建议设置OkHttpClient,不设置将使用默认的 .setRetryCount(1); //超时重连,本身1次,我这边设置1次,总共2次访问 } public static OkHttpClient initOkhttp(){ OkHttpClient client = new OkHttpClient.Builder() .sslSocketFactory(TrustAllCerts.createSSLSocketFactory()) .hostnameVerifier(new TrustAllCerts.TrustAllHostnameVerifier()) .build(); return client; } }
POST请求
private static void okgoPost(String method, HashMap<String,String> hashMap, OkGoCallback callback){ OkGo.<String>post(getIP()+method) .params(hashMap) .execute(new StringCallback() { @Override public void onSuccess(Response<String> response) { cajavascriptllback.callback(response.body()); } }); }
下载
OkGo.<File>get(uploadUrl) .tag(this) //.headers("header1", "headerValue1")// //.params("param1", "paramValue1")// .execute(new FileCallback( saveFilePath, saveName ) { @Override public void onStart(com.lzy.okgo.request.base.Request<File, ? extends com.lzy.okgo.request.base.Request> request) { super.onStart(request); MyLog.e("mylog","开始下载"); } @Override public void onSuccess(com.lzy.okgo.model.Response<File> response) { progress.getProgress(100,"success"); } @Override public void onError(com.lzy.okgo.model.Response<File> response) { super.onError(response); progress.getProgress(-1,"下载出错!"); } @Override public void downloadProgress(com.lzy.okgo.model.Progress pp) { super.downloadProgress(pp); int ppi = (int)(pp.fraction * 100); MyLog.e("mylog","progress:"+ppi); progress.getProgress(ppi,""); } });
网络请求框架-OkHttp
引入包
implementation 'com.squareup.okhttp3:okhttp:4.10.0'
封装
TrustAllCerts类 在OkGo中 。
private static String okhttp(String method , String json){ MyLog.e("mylog-url",getIP()+method); OkHttpClient client = new OkHttpClient.Builder() .sslSocketFactory(TrustAllCerts.createSSLSocketFactory()) //绕过https .hostnameVerifier(new TrustAllCerts.TrustAllHostnameVerifier()) //绕过https .build(); RequestBody body = RequestBody.create(json, JSON); Request request = new Request.Builder() .url( getIP()+method ) .post(body) .build(); try{ Response response = client.newCall(request).execute(); return Objects.requireNonNull(response.body()).string(); }catch (Exception e){ MyLog.e("mylog","error:\r\n"+e.getMessage()); return "error:\r\n"+e.getMessage(); } }
调用
GetList list = new GetList(flightDate,flightNo,sourceAirport, myApplication.getAppIp()); //参数类 //list.toString() 为 类转json字符串 String response = okhttp(GET_LIST,list.toString());
下载
/** * * @param uploadUrl 下载路径 * @param saveFilePath 保存路径 * @param saveName 保存文件名 ,如 XXX.apk * @param progress 回调函数,获取下载进度 */ public void downloadApk(String uploadUrl,String saveFilePath,String saveName,Progress progress) { // 创建OkHttpClient并配置自定义的TrustManager OkHttpClient client = new OkHttpClient.Builder() .sslSocketFactory(TrustAllCerts.createSSLSocketFactory()) .hostnameVerifier(new TrustAllCerts.TrustAllHostnameVerifier()) .build(); Request request = new Request.Builder() .url(uploadUrl) .build(); Call call = client.newCall(request); call.enqueue(new Callback() { @Override public void onFailure(@NotNull Call call, @NotNull IOException e) { progress.getProgress(-1,e.getMessage()); } @Override public void onResponse(@NotNull Call call, @NotNull Response response) throws IOException { //3824043 long fileMax = response.body().contentLength(); InputStream inputStream = Objects.requireNonNull(response.body()).byteStream(); File target = new File(saveFilePath,saveName); FileOutputStream fileOutputStream = new FileOutputStream(target); try { byte[] buffer = new byte[2048]; int len; while ((len = inputStream.read(buffer)) != -1) { fileOutputStream.write(buffer, 0, len); int p = (int) ((target.length() * 100) / fileMax); progress.getProgress(p,""); } fileOutputStream.flush(); } catch (IOException e) { e.printStackTrace(); } } }); }
以上就是Android封装常用工具类的示例详解的详细内容,更多关于Android工具类的资料请关注编程客栈(www.devze.com)其它相关文章!
精彩评论