关于Amoeba读取longblob字段的问题_MySQL
bitsCN.com
最近有一个应用使用Amoeba从几个库中读取MySQL中含有longblob字段的表,老是报Session was killed。
经查是Amoeba中可读通道的缓存大小引起的。原来在com.meidusa.amoeba.net.io.PacketInputStream类中,有一个属性maxPacketSize,限制了可读通道的缓存大小,如果当前读取的记录的长度大于maxPacketSize,就会报错。所以我们必须把它调大点。
Java代码
/** 最大容量 */
protected static final int MAX_BUFFER_CAPACITY = 1024 * 1024 * 2;
private int maxPacketSize = MAX_BUFFER_CAPACITY;
public int getMaxPacketSize() {
return maxPacketSize;
}
public void setMaxPacketSize(int maxPacketSize) {
this.maxPacketSize = maxPacketSize;
}
maxPacketSize默认是2MB,但是发现setMaxPacketSize方法没有在其它地方有调用,应该是不可配置的,因此我直接修改了MAX_BUFFER_CAPACITY,重新打包扔上去就没问题了。
另外,当maxPacketSize大小不足时,用SQLYog连代理时的时候,发现一个有趣的现象。假如我有一表,各字段长度如下:
field1 | field2
1M | 3M
如果我先执行:SELECT field2 FROM tab
这时出错:Lost connection to MySQL server during query
再执行:SELECT field1 FROM tab
SQLYog就没有响应了,然后amoeba抛OOM异常,屡试不爽。查DUMP文件后,发现AuthingableConnectionManager 和 Log4j的DailyRollingFileAppender塞满了内存。

热AI工具

Undresser.AI Undress
人工智能驱动的应用程序,用于创建逼真的裸体照片

AI Clothes Remover
用于从照片中去除衣服的在线人工智能工具。

Undress AI Tool
免费脱衣服图片

Clothoff.io
AI脱衣机

Video Face Swap
使用我们完全免费的人工智能换脸工具轻松在任何视频中换脸!

热门文章

热工具

记事本++7.3.1
好用且免费的代码编辑器

SublimeText3汉化版
中文版,非常好用

禅工作室 13.0.1
功能强大的PHP集成开发环境

Dreamweaver CS6
视觉化网页开发工具

SublimeText3 Mac版
神级代码编辑软件(SublimeText3)

热门话题

在Go语言中,通道(chan)是goroutine之间通信的管道,是goroutine与另一个goroutine通信的媒介。通道是一种技术,它允许一个goroutine将数据发送到另一个goroutine;默认情况下,通道是双向的,这意味着goroutine可以通过同一通道发送或接收数据。

在Go中,我们可以使用chan关键字将函数通道作为函数参数传递,从而轻松地在函数之间共享和传递数据。具体操作步骤如下:创建一个通道来传递特定类型的数据。在函数中使用chan关键字和通道名称将通道作为参数传递。使用单向通道

通道是Go语言中用于在并发函数间安全传递数据的通信机制,提供的数据竞争保护避免直接访问共享内存。通道类型包括无缓冲通道(chanT)和缓冲通道(chanT,int)。规则包括发送值(

管道和通道是Go中实现并行性与并发性的重要工具。它们可以通过以下几种方式优化Go函数性能:管道:实现并行I/O,提高吞吐量。通道:缓冲管道,管理计算密集型任务的并发执行。选择性接收:从多个通道中接收数据,提高效率。

通过Golang实现SelectChannelsGo并发式编程的效率提升引言:在当今的软件开发领域,高效的并发编程是至关重要的。并发编程可以最大程度地利用现代处理器的多核能力,提高程序的执行效率和性能。Golang是一种以并发性为重点设计的编程语言,通过其内置的goroutine和channel机制,可以轻松实现高效的并发编程。本文将通过Golang中的

在golang中,可以使用close()函数来关闭通道,语法“close(msg_chan)”。 通道(chan)是一种系统资源,因此在不需要使用chan 时,需要使用内置函数close来手动关闭管道。注如果向一个已经关闭的管道发送数据,那么程序会pannic。

在Go语言中:函数并发控制允许使用关键字go或goroutine创建并发执行的函数。通道是一个缓冲队列,用于在并发函数之间传递值,提供同步和通信。可使用

Go语言中,通道的内部结构包含元素类型、缓冲区指针、互斥锁、发送和接收队列。收发机制涉及唤醒goroutine来发送或接收数据。通道分为缓冲和无缓冲两种。缓冲通道允许goroutine在没有接收者的情况下发送数据,而无缓冲通道则需要发送前有接收者。
