123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293 |
- //------------------------------------------------------------
- // Game Framework
- // Copyright © 2013-2021 loyalsoft. All rights reserved.
- // Homepage: http://www.game7000.com/
- // Feedback: http://www.game7000.com/
- //------------------------------------------------------------
- using GameFramework;
- using GameFramework.FileSystem;
- using System;
- using System.IO;
- using UnityEngine;
- namespace UnityGameFramework.Runtime
- {
- /// <summary>
- /// 安卓文件系统流。
- /// </summary>
- public sealed class AndroidFileSystemStream : FileSystemStream
- {
- private static readonly string SplitFlag = "!/assets/";
- private static readonly int SplitFlagLength = SplitFlag.Length;
- private static readonly AndroidJavaObject s_AssetManager = null;
- private static readonly IntPtr s_InternalReadMethodId = IntPtr.Zero;
- private static readonly jvalue[] s_InternalReadArgs = null;
- private readonly AndroidJavaObject m_FileStream;
- private readonly IntPtr m_FileStreamRawObject;
- static AndroidFileSystemStream()
- {
- AndroidJavaClass unityPlayer = new AndroidJavaClass("com.unity3d.player.UnityPlayer");
- if (unityPlayer == null)
- {
- throw new GameFrameworkException("Unity player is invalid.");
- }
- AndroidJavaObject currentActivity = unityPlayer.GetStatic<AndroidJavaObject>("currentActivity");
- if (currentActivity == null)
- {
- throw new GameFrameworkException("Current activity is invalid.");
- }
- AndroidJavaObject assetManager = currentActivity.Call<AndroidJavaObject>("getAssets");
- if (assetManager == null)
- {
- throw new GameFrameworkException("Asset manager is invalid.");
- }
- s_AssetManager = assetManager;
- IntPtr inputStreamClassPtr = AndroidJNI.FindClass("java/io/InputStream");
- s_InternalReadMethodId = AndroidJNIHelper.GetMethodID(inputStreamClassPtr, "read", "([BII)I");
- s_InternalReadArgs = new jvalue[3];
- AndroidJNI.DeleteLocalRef(inputStreamClassPtr);
- currentActivity.Dispose();
- unityPlayer.Dispose();
- }
- /// <summary>
- /// 初始化安卓文件系统流的新实例。
- /// </summary>
- /// <param name="fullPath">要加载的文件系统的完整路径。</param>
- /// <param name="access">要加载的文件系统的访问方式。</param>
- /// <param name="createNew">是否创建新的文件系统流。</param>
- public AndroidFileSystemStream(string fullPath, FileSystemAccess access, bool createNew)
- {
- if (string.IsNullOrEmpty(fullPath))
- {
- throw new GameFrameworkException("Full path is invalid.");
- }
- if (access != FileSystemAccess.Read)
- {
- throw new GameFrameworkException(Utility.Text.Format("'{0}' is not supported in AndroidFileSystemStream.", access.ToString()));
- }
- if (createNew)
- {
- throw new GameFrameworkException("Create new is not supported in AndroidFileSystemStream.");
- }
- int position = fullPath.LastIndexOf(SplitFlag, StringComparison.Ordinal);
- if (position < 0)
- {
- throw new GameFrameworkException("Can not find split flag in full path.");
- }
- string fileName = fullPath.Substring(position + SplitFlagLength);
- m_FileStream = InternalOpen(fileName);
- if (m_FileStream == null)
- {
- throw new GameFrameworkException(Utility.Text.Format("Open file '{0}' from Android asset manager failure.", fullPath));
- }
- m_FileStreamRawObject = m_FileStream.GetRawObject();
- }
- /// <summary>
- /// 获取或设置文件系统流位置。
- /// </summary>
- public override long Position
- {
- get
- {
- throw new GameFrameworkException("Get position is not supported in AndroidFileSystemStream.");
- }
- set
- {
- Seek(value, SeekOrigin.Begin);
- }
- }
- /// <summary>
- /// 获取文件系统流长度。
- /// </summary>
- public override long Length
- {
- get
- {
- return InternalAvailable();
- }
- }
- /// <summary>
- /// 设置文件系统流长度。
- /// </summary>
- /// <param name="length">要设置的文件系统流的长度。</param>
- public override void SetLength(long length)
- {
- throw new GameFrameworkException("SetLength is not supported in AndroidFileSystemStream.");
- }
- /// <summary>
- /// 定位文件系统流位置。
- /// </summary>
- /// <param name="offset">要定位的文件系统流位置的偏移。</param>
- /// <param name="origin">要定位的文件系统流位置的方式。</param>
- public override void Seek(long offset, SeekOrigin origin)
- {
- if (origin == SeekOrigin.End)
- {
- Seek(Length + offset, SeekOrigin.Begin);
- return;
- }
- if (origin == SeekOrigin.Begin)
- {
- InternalReset();
- }
- while (offset > 0)
- {
- long skip = InternalSkip(offset);
- if (skip < 0)
- {
- return;
- }
- offset -= skip;
- }
- }
- /// <summary>
- /// 从文件系统流中读取一个字节。
- /// </summary>
- /// <returns>读取的字节,若已经到达文件结尾,则返回 -1。</returns>
- public override int ReadByte()
- {
- return InternalRead();
- }
- /// <summary>
- /// 从文件系统流中读取二进制流。
- /// </summary>
- /// <param name="buffer">存储读取文件内容的二进制流。</param>
- /// <param name="startIndex">存储读取文件内容的二进制流的起始位置。</param>
- /// <param name="length">存储读取文件内容的二进制流的长度。</param>
- /// <returns>实际读取了多少字节。</returns>
- public override int Read(byte[] buffer, int startIndex, int length)
- {
- byte[] result = null;
- int bytesRead = InternalRead(length, out result);
- Array.Copy(result, 0, buffer, startIndex, bytesRead);
- return bytesRead;
- }
- /// <summary>
- /// 向文件系统流中写入一个字节。
- /// </summary>
- /// <param name="value">要写入的字节。</param>
- public override void WriteByte(byte value)
- {
- throw new GameFrameworkException("WriteByte is not supported in AndroidFileSystemStream.");
- }
- /// <summary>
- /// 向文件系统流中写入二进制流。
- /// </summary>
- /// <param name="buffer">存储写入文件内容的二进制流。</param>
- /// <param name="startIndex">存储写入文件内容的二进制流的起始位置。</param>
- /// <param name="length">存储写入文件内容的二进制流的长度。</param>
- public override void Write(byte[] buffer, int startIndex, int length)
- {
- throw new GameFrameworkException("Write is not supported in AndroidFileSystemStream.");
- }
- /// <summary>
- /// 将文件系统流立刻更新到存储介质中。
- /// </summary>
- public override void Flush()
- {
- throw new GameFrameworkException("Flush is not supported in AndroidFileSystemStream.");
- }
- /// <summary>
- /// 关闭文件系统流。
- /// </summary>
- public override void Close()
- {
- InternalClose();
- m_FileStream.Dispose();
- }
- private AndroidJavaObject InternalOpen(string fileName)
- {
- return s_AssetManager.Call<AndroidJavaObject>("open", fileName);
- }
- private int InternalAvailable()
- {
- return m_FileStream.Call<int>("available");
- }
- private void InternalClose()
- {
- m_FileStream.Call("close");
- }
- private int InternalRead()
- {
- return m_FileStream.Call<int>("read");
- }
- private int InternalRead(int length, out byte[] result)
- {
- #if UNITY_2019_2_OR_NEWER
- #pragma warning disable CS0618
- #endif
- IntPtr resultPtr = AndroidJNI.NewByteArray(length);
- #if UNITY_2019_2_OR_NEWER
- #pragma warning restore CS0618
- #endif
- int offset = 0;
- int bytesLeft = length;
- while (bytesLeft > 0)
- {
- s_InternalReadArgs[0] = new jvalue() { l = resultPtr };
- s_InternalReadArgs[1] = new jvalue() { i = offset };
- s_InternalReadArgs[2] = new jvalue() { i = bytesLeft };
- int bytesRead = AndroidJNI.CallIntMethod(m_FileStreamRawObject, s_InternalReadMethodId, s_InternalReadArgs);
- if (bytesRead <= 0)
- {
- break;
- }
- offset += bytesRead;
- bytesLeft -= bytesRead;
- }
- #if UNITY_2019_2_OR_NEWER
- #pragma warning disable CS0618
- #endif
- result = AndroidJNI.FromByteArray(resultPtr);
- #if UNITY_2019_2_OR_NEWER
- #pragma warning restore CS0618
- #endif
- AndroidJNI.DeleteLocalRef(resultPtr);
- return offset;
- }
- private void InternalReset()
- {
- m_FileStream.Call("reset");
- }
- private long InternalSkip(long offset)
- {
- return m_FileStream.Call<long>("skip", offset);
- }
- }
- }
|