关于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 기반 앱

AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool
무료로 이미지를 벗다

Clothoff.io
AI 옷 제거제

Video Face Swap
완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

인기 기사

뜨거운 도구

메모장++7.3.1
사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전
중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경

드림위버 CS6
시각적 웹 개발 도구

SublimeText3 Mac 버전
신 수준의 코드 편집 소프트웨어(SublimeText3)

뜨거운 주제











Go 언어에서 채널(chan)은 고루틴 간의 통신 파이프이자 고루틴이 다른 고루틴과 통신하는 매체입니다. 채널은 하나의 고루틴이 다른 고루틴으로 데이터를 보낼 수 있게 해주는 기술입니다. 기본적으로 채널은 양방향입니다. 즉, 고루틴은 동일한 채널을 통해 데이터를 보내거나 받을 수 있습니다.

Go에서는 chan 키워드를 사용하여 함수 채널을 함수 인수로 전달함으로써 함수 간에 데이터를 쉽게 공유하고 전달할 수 있습니다. 구체적인 단계는 다음과 같습니다. 특정 유형의 데이터를 전달하는 채널을 만듭니다. chan 키워드와 채널 이름을 사용하여 함수의 매개변수로 채널을 전달합니다. 단방향 채널을 사용하세요

채널은 동시 기능 간에 데이터를 안전하게 전송하기 위한 Go 언어의 통신 메커니즘입니다. 채널은 공유 메모리에 대한 직접 액세스를 방지하기 위해 데이터 경합 보호 기능을 제공합니다. 채널 유형에는 버퍼링되지 않은 채널(chanT)과 버퍼링된 채널(chanT, int)이 포함됩니다. 규칙에는 값 전송이 포함됩니다(

파이프와 채널은 Go에서 병렬성과 동시성을 달성하는 데 중요한 도구입니다. 다음과 같은 방법으로 Go 기능 성능을 최적화할 수 있습니다. 파이프라인: 병렬 I/O를 구현하고 처리량을 향상시킵니다. 채널: 계산 집약적인 작업의 동시 실행을 관리하는 버퍼링된 파이프라인입니다. 선택적 수신: 여러 채널에서 데이터를 수신하여 효율성을 높입니다.

Golang을 통한 SelectChannelsGo 동시 프로그래밍 효율성 향상 구현 소개: 오늘날의 소프트웨어 개발 분야에서는 효율적인 동시 프로그래밍이 매우 중요합니다. 동시 프로그래밍은 최신 프로세서의 멀티 코어 기능을 최대한 활용하고 프로그램 실행 효율성과 성능을 향상시킬 수 있습니다. Golang은 동시성을 염두에 두고 설계된 프로그래밍 언어로, 내장된 고루틴과 채널 메커니즘을 통해 효율적인 동시 프로그래밍을 쉽게 달성할 수 있습니다. 이 기사에서는 Golang을 사용하여

golang에서는 close() 함수를 사용하여 채널을 닫을 수 있으며 구문은 "close(msg_chan)"입니다. 채널(chan)은 시스템 리소스이므로 chan을 사용할 필요가 없는 경우에는 내장된 close 기능을 사용하여 수동으로 파이프를 닫아야 합니다. 참고: 닫힌 파이프로 데이터를 보내면 프로그램이 패닉 상태가 됩니다.

Go 언어: 함수 동시성 제어를 사용하면 go 또는 goroutine 키워드를 사용하여 동시에 실행되는 함수를 생성할 수 있습니다. 채널은 동시 기능 간에 값을 전달하고 동기화 및 통신을 제공하는 데 사용되는 버퍼 큐입니다. 사용할 수 있다

Go 언어에서 채널의 내부 구조에는 요소 유형, 버퍼 포인터, 뮤텍스 잠금, 보내기 및 받기 대기열이 포함됩니다. 송신 및 수신 메커니즘에는 데이터를 보내거나 수신하기 위해 고루틴을 깨우는 것이 포함됩니다. 채널은 버퍼링된 채널과 버퍼링되지 않은 채널로 구분됩니다. 버퍼링된 채널을 사용하면 고루틴이 수신기 없이 데이터를 보낼 수 있는 반면, 버퍼링되지 않은 채널은 전송하기 전에 수신기가 필요합니다.
