메뉴
Java 25 development patterns for the crypto-scout ecosystem including microservices, ActiveJ, and async I/O
기본적으로 소스를 먼저 확인하는 Prompt가 선택됩니다. 직접 명령으로 전환하거나 로컬 사본을 다운로드할 수도 있습니다.
설치 여부를 결정하기 전에 SKILL.md와 SkillsMP에 표시된 보조 파일을 읽어 보세요.
Codex 또는 Claude로 설치 이 Prompt를 복사해 Codex, Claude 또는 다른 어시스턴트에 붙여 넣으면 Skill 페이지를 검토하고 설치를 진행할 수 있습니다.
직접 명령은 검토 Prompt를 거치지 않습니다. 실행하기 전에 소스를 확인하세요.
npx skills add https://github.com/akarazhev/crypto-scout --skill java-ecosystem명령은 한 줄로 유지됩니다. 복사하기 전에 가로로 스크롤해 전체 내용을 확인하세요.
로컬 사본을 원하시나요? SkillsMP에서 현재 제공할 수 있는 파일을 다운로드하세요.
SKILL.md 표시 중
SOC 직업 분류 기준
| name | java-ecosystem |
| description | Java 25 development patterns for the crypto-scout ecosystem including microservices, ActiveJ, and async I/O |
| license | MIT |
| compatibility | opencode |
| metadata | {"language":"java","version":"25","framework":"activej","domain":"microservices"} |
Provide comprehensive guidance for Java 25 development across the crypto-scout ecosystem, covering microservice patterns, ActiveJ framework usage, and async I/O operations.
public final class Service extends Launcher {
@Override
protected Module getModule() {
return combine(
JmxModule.create(),
ServiceGraphModule.create(),
CoreModule.create(),
ServiceModule.create(),
WebModule.create()
);
}
Exception {
ConfigValidator.validate();
}
Exception {
awaitShutdown();
}
Exception {
().launch(args);
}
}
| Module | Purpose | Services Using |
|---|---|---|
| CoreModule | Reactor and virtual thread executor | All services |
| WebModule | HTTP server, clients, health routes | All services |
| ClientModule | AMQP publisher lifecycle | crypto-scout-client |
| CollectorModule | Repositories and services | crypto-scout-collector |
| AnalystModule | Analysis services and transformers | crypto-scout-analyst |
| BybitSpotModule | Bybit spot WebSocket consumers | crypto-scout-client |
| BybitLinearModule | Bybit linear WebSocket consumers | crypto-scout-client |
| CmcParserModule | CoinMarketCap parser | crypto-scout-client |
public final class MyService extends AbstractReactive implements ReactiveService {
private final Executor executor;
private volatile Resource resource;
public static MyService create(NioReactor reactor, Executor executor) {
return new MyService(reactor, executor);
}
private MyService(NioReactor reactor, Executor executor) {
super(reactor);
this.executor = executor;
}
@Override
public Promise<Void> start() {
return Promise.ofBlocking(executor, () -> {
// Initialize resources
resource = createResource();
});
}
@Override
public Promise<Void> stop() {
return Promise.ofBlocking(executor, () -> {
// Cleanup resources
closeResource(resource);
resource = null;
});
}
}
public final class AnalystTransformer extends AbstractStreamTransformer<StreamPayload, StreamPayload> {
@Override
protected StreamDataAcceptor<StreamPayload> onResumed(final StreamDataAcceptor<StreamPayload> output) {
return in -> {
try {
final var result = process(in);
output.accept(result);
} catch (final Exception ex) {
LOGGER.error("Processing failed", ex);
output.accept(new StreamPayload(in.stream(), in.offset(), null));
}
};
}
}
1-23: MIT License header
25: Package declaration
26: Blank line
27+: Imports (java.* → third-party → static)
Blank line
Class declaration
import java.io.IOException;
import java.nio.file.Path;
import java.time.Duration;
import com.rabbitmq.stream.Environment;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import static com.github.akarazhev.cryptoscout.config.Constants.AmqpConfig.AMQP_RABBITMQ_HOST;
| Element | Convention | Example |
|---|---|---|
| Classes | PascalCase | StreamService, AmqpPublisher |
| Methods | camelCase with verb | waitForDatabaseReady |
| Constants | UPPER_SNAKE_CASE | JDBC_URL, DB_USER |
| Locals | final var | final var timeout |
| Tests | <Class>Test | AmqpPublisherTest |
| Test methods | should<Subject><Action> | shouldPublishPayload |
// Invalid state
if (resource == null) {
throw new IllegalStateException("Resource not initialized: " + name);
}
// Try-with-resources
try (final var conn = dataSource.getConnection();
final var stmt = conn.prepareStatement(sql)) {
// Use resources
} catch (final SQLException e) {
throw new IllegalStateException("Database error", e);
}
// Interrupt handling
try {
Thread.sleep(duration.toMillis());
} catch (final InterruptedException e) {
Thread.currentThread().interrupt();
}
JCryptoLibException (base)
├── ApiException
├── CmcApiException
├── StreamException
├── CircuitBreakerException
├── RateLimiterException
├── HealthCheckException
├── ResilienceException
└── ConfigurationException
Usage:
// In jcryptolib
try {
// operation
} catch (final SomeException e) {
throw new StreamException("Message", e);
}
// In services
} catch (final SQLException e) {
throw new IllegalStateException("Database operation failed", e);
}
final class MyServiceTest {
@BeforeAll
static void setUp() {
PodmanCompose.up();
}
@AfterAll
static void tearDown() {
PodmanCompose.down();
}
@Test
void shouldServiceStartSuccessfully() throws Exception {
final var service = createTestService();
assertTrue(service.start().isResult());
}
}
// Load test fixtures
final var spotKlines = MockData.get(
MockData.Source.BYBIT_SPOT,
MockData.Type.KLINE_1
);
final var fgi = MockData.get(
MockData.Source.CRYPTO_SCOUT,
MockData.Type.FGI
);
static final String VALUE = System.getProperty("property.key", "defaultValue");
static final int PORT = Integer.parseInt(System.getProperty("port.key", "5552"));
static final Duration TIMEOUT = Duration.ofMinutes(Long.getLong("timeout.key", 3L));
| Class | Purpose |
|---|---|
BybitStream | WebSocket streaming with resilience |
BybitParser | REST API data fetching |
CmcParser | CoinMarketCap data parser |
AnalystEngine | Technical analysis indicators |
Payload<T> | Stream data container |
CircuitBreaker | Resilience pattern |
RateLimiter | Rate limiting |
JsonUtils | JSON serialization |
| Class | Purpose |
|---|---|
Client | Service launcher |
AmqpPublisher | RabbitMQ Streams publisher |
AbstractBybitStreamConsumer | Base for Bybit consumers |
CmcParserConsumer | CMC data consumer |
| Class | Purpose |
|---|---|
Collector | Service launcher |
StreamService | Stream consumer orchestrator |
BybitStreamService | Bybit data processor |
CryptoScoutService | CMC data processor |
*Repository | Database access |
| Class | Purpose |
|---|---|
Analyst | Service launcher |
StreamService | Stream processing orchestrator |
DataService | Async data processing |
AnalystTransformer | Stream transformer |
StreamPublisher | Output publisher |
Use this skill when:
Maven build configuration for the crypto-scout multi-module Java 25 project
Podman Compose orchestration for crypto-scout services including RabbitMQ, TimescaleDB, and microservices
High-level architecture and design patterns for the crypto-scout ecosystem