程序包 com.agentsflex.core.file2text.source

类 HttpDocumentSource

java.lang.Object

com.agentsflex.core.file2text.source.HttpDocumentSource

所有已实现的接口:

DocumentSource

public class HttpDocumentSource
extends Object
implements DocumentSource

从 HTTP/HTTPS URL 读取文档的输入源，支持缓存（避免重复请求） 自动判断使用内存缓存还是临时文件缓存

字段概要

字段

修饰符和类型	字段	说明
private byte[]	cachedBytes
private final Consumer<HttpURLConnection>	connectionCustomizer
private final int	connectTimeout
private static final int	DEFAULT_CONNECT_TIMEOUT
private static final int	DEFAULT_READ_TIMEOUT
private final AtomicBoolean	downloaded
private static final long	MEMORY_THRESHOLD
private final String	mimeType
private final String	providedFileName
private final int	readTimeout
private String	resolvedFileName
private String	resolvedMimeType
private File	tempFile
private final String	url

构造器概要

构造器

构造器	说明
HttpDocumentSource(String url)
HttpDocumentSource(String url, String fileName)
HttpDocumentSource(String url, String fileName, String mimeType)
HttpDocumentSource(String url, String fileName, String mimeType, int connectTimeout, int readTimeout, Consumer<HttpURLConnection> connectionCustomizer)

方法概要

修饰符和类型	方法	说明
void	cleanup()	清理临时文件
private HttpURLConnection	createConnection()
private String	detectFileName()
private void	downloadIfNeeded()	下载一次，缓存结果
private String	extractFileNameFromHeader(HttpURLConnection conn)
private String	extractFileNameFromUrl()
long	getCachedSize()	获取缓存大小（用于调试）
String	getFileName()
String	getMimeType()
InputStream	openStream()
static String	sanitizeFileName(String filename)
private String	validateUrl(String url)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

DEFAULT_CONNECT_TIMEOUT

private static final int DEFAULT_CONNECT_TIMEOUT

另请参阅:

• 常量字段值

DEFAULT_READ_TIMEOUT

private static final int DEFAULT_READ_TIMEOUT

另请参阅:

• 常量字段值

MEMORY_THRESHOLD

private static final long MEMORY_THRESHOLD

另请参阅:

• 常量字段值

url

private final String url

providedFileName

private final String providedFileName

mimeType

private final String mimeType

connectTimeout

private final int connectTimeout

readTimeout

private final int readTimeout

connectionCustomizer

private final Consumer<HttpURLConnection> connectionCustomizer

cachedBytes

private volatile byte[] cachedBytes

tempFile

private volatile File tempFile

resolvedFileName

private volatile String resolvedFileName

resolvedMimeType

private volatile String resolvedMimeType

downloaded

private final AtomicBoolean downloaded

构造器详细资料

HttpDocumentSource

public HttpDocumentSource(String url)

HttpDocumentSource

public HttpDocumentSource(String url,
 String fileName)

HttpDocumentSource

public HttpDocumentSource(String url,
 String fileName,
 String mimeType)

HttpDocumentSource

public HttpDocumentSource(String url,
 String fileName,
 String mimeType,
 int connectTimeout,
 int readTimeout,
 Consumer<HttpURLConnection> connectionCustomizer)

方法详细资料

validateUrl

private String validateUrl(String url)

getFileName

public String getFileName()

指定者:

getFileName 在接口中 DocumentSource

detectFileName

private String detectFileName()

extractFileNameFromUrl

private String extractFileNameFromUrl()

extractFileNameFromHeader

private String extractFileNameFromHeader(HttpURLConnection conn)

sanitizeFileName

public static String sanitizeFileName(String filename)

getMimeType

public String getMimeType()

指定者:

getMimeType 在接口中 DocumentSource

openStream

public InputStream openStream()
                       throws IOException

指定者:

openStream 在接口中 DocumentSource

抛出:

IOException

downloadIfNeeded

private void downloadIfNeeded()
                       throws IOException

下载一次，缓存结果

抛出:

IOException

createConnection

private HttpURLConnection createConnection()
                                    throws IOException

抛出:

IOException

getCachedSize

public long getCachedSize()

获取缓存大小（用于调试）

cleanup

public void cleanup()

清理临时文件

指定者:

cleanup 在接口中 DocumentSource