Adapter Pattern
0. 들어가면서
스프링 프레임워크를 사용하다보면 Adapter라는 단어로 끝나는 단어들이 많이 보입니다.
어렴풋이 어댑터 패턴(adapter pattern)이 적용되었을 것이라 생각했지만, 어째서 어댑터 패턴을 사용하는지 깊게 고민해보진 않았습니다.
최근에 스프링 내부를 들여다보면서 다양한 어댑터들을 발견했습니다.
디자인 패턴의 구체적인 용도를 알고 코드를 분석하면 더 많은 인사이트(insight)를 얻을 수 있을 것 같아서 포스트로 정리해보았습니다.
1. 어댑터 패턴(Adapter Pattern)
Design Patterns: Elements of Reusable Object Oriented Software
클래스의 인터페이스를 사용자가 기대하는 인터페이스 형태로 적응(변환)시킵니다. 서로 일치하지 않는 인터페이스를 갖는 클래스들을 함께 동작시킵니다.
GoF 디자인 패턴 책을 읽다보면 위에 설명처럼 이해하기 난해한 문장이 많습니다.
다른 분들은 이해하셨을지 모르겠지만, 저에겐 다소 어려운 느낌입니다.
GoF 디자인 패턴과 다른 레퍼런스(reference)들을 읽고, 제 스스로 이해할 수 있도록 다시 정리하였습니다.
- 어댑터 패턴은 인터페이스를 통한 다형성(polymorphism)을 이용한 패턴입니다.
- 기존 클래스를 대신할 새로운 기능의 클래스를 사용하기 위한 디자인 패턴입니다.
- 어댑터 패턴은 두 가지 방법을 통해 운영 중인 코드를 최소한의 부담으로 변경할 수 있도록 도움을 줍니다.
- 새로운 기능을 제공하는 클래스를 상속하여 인터페이스 구현 메소드 내부에서 부모의 메소드 호출
- 새로운 기능을 제공하는 인스턴스에게 일을 위임하여 인터페이스 구현 메소드 내부에서 인스턴스 메소드 호출
어댑터 패턴 클래스 다이어그램
- 어댑터 패턴을 이해하기 위해선 패턴을 이루는 몇 가지 요소들에 대해 이해할 필요가 있습니다.
- 클라이언트(Client)
- 대상 인터페이스를 사용하는 클래스입니다.
- 클라이언트 클래스 입장에선 인터페이스라는 껍데기만 사용하기 때문에 코드에 변경이 없습니다.
- 대상 인터페이스(Target Interface)
- 클라이언트가 사용할 기능을 명세하고 있는 인터페이스입니다.
- 레거시 클래스는 인터페이스를 구현하고 있습니다.(implement)
- 어댑터(Adapter)
- 기능 확장을 위해 대상 인터페이스를 구현한 클래스입니다.
- 오버라이드(override) 한 메소드 내부를 신규 기능을 제공하는 코드로 대체합니다.
- 어댑티(Adaptee)
- 새로운 기능을 제공하는 클래스입니다.
- 어댑터는 어댑티를 상속(inheritance)받거나, 어댑티에게 기능을 위임(delegating)합니다.
2. 어댑터 패턴 적용하기
이해도를 높히고자 간단한 예시 코드를 작성해보았습니다. 어댑터 패턴을 적용하기 위한 시나리오와 클래스 구조는 다음과 같습니다.
- 현재 사용자 세션 정보를 데이터베이스에 저장하고 있습니다.
- 속도 개선을 위해 레디스(redis) 같은 캐시 서비스를 사용하고 싶습니다.
- 운영하는 세션 관리 코드를 큰 변경 없이 새로운 기능으로 대체하고 싶습니다.
SessionHandler클래스- 어댑터 패턴에서 클라이언트 클래스 역할을 수행합니다.
- 어플리케이션은
SessionHandler클래스를 통해 사용자 세션 정보를 저장, 획득, 삭제합니다.
SessionRegistry인터페이스- 어댑터 패턴에서 대상 인터페이스 역할을 수행합니다.
SessionHandler클래스는SessionRegistry구현체를 통해 세션 정보를 저장, 획득, 삭제합니다.
JdbcSessionRegistry클래스- 어댑터 패턴에서 레거시 기능을 제공하는 클래스입니다.
SessionRegistry인터페이스를 구현하였으며, 데이터베이스에 세션 정보를 저장, 획득, 삭제합니다.
클래스 다이어그램
2.1. 기존 레거시 코드 살펴보기
2.1.1. SessionHandler 클래스
- 어댑터 패턴에서 클라이언트 역할입니다.
getSession메소드SessionRegistry구현체를 이용하여sessionId에 해당하는 세션 정보를 가져옵니다.- 세션 정보가 없다면 예외를 발생시킵니다.
putSession메소드SessionRegistry구현체를 이용하여sessionId에 매칭되는 세션 정보를 입력합니다.- 처리 시 예외가 발생하면 이를 한 차례 묶어서 던집니다.
deleteSession메소드SessionRegistry구현체를 이용하여sessionId에 해당하는 세션 정보를 삭제합니다.- 처리 시 예외가 발생하면 이를 한 차례 묶어서 던집니다.
package action.in.blog;
public class SessionHandler {
private final SessionRegistry sessionRegistry;
public SessionHandler(SessionRegistry sessionRegistry) {
this.sessionRegistry = sessionRegistry;
}
public Object getSession(String sessionId) {
Object session = sessionRegistry.getSession(sessionId);
if (session == null) {
throw new RuntimeException("session does not exist");
}
return session;
}
public void putSession(String sessionId, Object session) {
try {
sessionRegistry.putSession(sessionId, session);
} catch (RuntimeException re) {
new RuntimeException("error when putting session", re);
}
}
public void deleteSession(String sessionId) {
try {
sessionRegistry.deleteSession(sessionId);
} catch (RuntimeException re) {
new RuntimeException("error when deleting session", re);
}
}
}
2.1.2. SessionRegistry 인터페이스
- 어댑터 패턴에서 대상 인터페이스 역할입니다.
- 세션 레지스트리로서 세션을 저장, 삭제, 조회하는 기능을 제공합니다.
package action.in.blog;
public interface SessionRegistry {
Object getSession(String sessionId);
void putSession(String sessionId, Object session);
void deleteSession(String sessionId);
}
2.1.3. JdbcSessionRegistry 클래스
- 기존에 사용하는 레거시 코드입니다.
- 대상 인터페이스를 구현하고 있습니다.
- 실제 쿼리를 수행하지 않고 로그로 기능을 표현하였습니다.
package action.in.blog;
public class JdbcSessionRegistry implements SessionRegistry {
@Override
public Object getSession(String sessionId) {
System.out.println("select s from tb_session s where session_id = " + sessionId);
return new Object();
}
@Override
public void putSession(String sessionId, Object session) {
System.out.println(
" insert into tb_session " +
" (session_id, session) " +
" values " +
" (" + sessionId + ", " + session + " )" +
" on duplicate key update " +
" session=" + session
);
}
@Override
public void deleteSession(String sessionId) {
System.out.println("delete from tb_session s where session_id = " + sessionId);
}
}
2.1.4. RedisSessionClient 클래스
- 어댑터 패턴에서 어댑티(adaptee) 역할입니다.
- 레디스를 이용한 세션 관리 기능을 제공합니다.
- 실제 기능 대신 로그로 기능을 표현하였습니다.
- 타 부서에서 클래스 같은 라이브러리 형태로 제공받은 기능이라고 생각하면 이해하는데 도움이 됩니다.
- 클래스로 받았으므로 개발자가 직접 수정 불가능합니다.
package action.in.blog;
public class RedisSessionClient {
public Object get(String sessionId) {
System.out.println("find session by session_id(" + sessionId + ") from redis");
return new Object();
}
public void post(String sessionId, Object session) {
System.out.println("post session info(" +
session +
") with session_id(" +
sessionId +
") into redis");
}
public void delete(String sessionId) {
System.out.println("delete session by session_id(" + sessionId + ") from redis");
}
}
2.2. 어댑터 클래스 만들기
기존 레지스트리를 사용하는 코드를 레디스 클라이언트를 사용할 수 있도록 확장합니다. 중간 어댑터 클래스가 우리가 일상 생활에 사용하는 콘센트 어댑터처럼 중간 변환 작업을 수행해줍니다. 세션 핸들러 쪽에선 여전히 세션 레지스트리를 사용하는 것처럼 보이지만, 실제 내부에선 기존과 전혀 다른 메커니즘으로 세션 관리가 수행됩니다.
2.2.1. 클래스 상속 어댑터 패턴
클래스 상속을 통해 어댑터 패턴을 구현합니다.
어댑터 클래스
- 어댑티 클래스를 부모 클래스로 상속받습니다.
- 대상 인터페이스를 구현합니다.
- 대상 인터페이스 내부 기능을 부모 클래스의 기능으로 대체합니다.
package action.in.blog.inheritance;
import action.in.blog.RedisSessionClient;
import action.in.blog.SessionRegistry;
public class ClientRegistryAdapter extends RedisSessionClient implements SessionRegistry {
@Override
public Object getSession(String sessionId) {
return super.get(sessionId);
}
@Override
public void putSession(String sessionId, Object session) {
super.post(sessionId, session);
}
@Override
public void deleteSession(String sessionId) {
super.delete(sessionId);
}
}
코드 사용 위치 변경
SessionHandler클래스를 생성하는 코드만 변경합니다.JdbcSessionRegistry대신ClientRegistryAdapter인스턴스를 전달힙니다.
- 레거시 코드 변경은 없습니다.
SessionHandler클래스SessionRegistry인터페이스JdbcSessionRegistry클래스
package action.in.blog.inheritance;
import action.in.blog.SessionHandler;
public class InheritanceUsage {
public static void main(String[] args) {
// legacy
// SessionHandler sessionHandler = new SessionHandler(new JdbcSessionRegistry());
// new
ClientRegistryAdapter adapter = new ClientRegistryAdapter();
SessionHandler sessionHandler = new SessionHandler(adapter);
sessionHandler.getSession("J12345");
}
}
변경된 클래스 다이어그램
2.2.2. 인스턴스 어댑터 패턴
위임을 통해 어댑터 패턴을 구현합니다.
어댑터 클래스
package action.in.blog.delegate;
import action.in.blog.RedisSessionClient;
import action.in.blog.SessionRegistry;
public class ClientRegistryAdapter implements SessionRegistry {
private final RedisSessionClient redisSessionClient;
public ClientRegistryAdapter(RedisSessionClient redisSessionClient) {
this.redisSessionClient = redisSessionClient;
}
@Override
public Object getSession(String sessionId) {
return redisSessionClient.get(sessionId);
}
@Override
public void putSession(String sessionId, Object session) {
redisSessionClient.post(sessionId, session);
}
@Override
public void deleteSession(String sessionId) {
redisSessionClient.delete(sessionId);
}
}
코드 사용 위치 변경
SessionHandler클래스를 생성하는 코드만 변경합니다.ClientRegistryAdapter에게RedisSessionClient인스턴스를 전달합니다.JdbcSessionRegistry대신ClientRegistryAdapter인스턴스를 전달힙니다.
- 레거시 코드 변경은 없습니다.
SessionHandler클래스SessionRegistry인터페이스JdbcSessionRegistry클래스
package action.in.blog.delegate;
import action.in.blog.RedisSessionClient;
import action.in.blog.SessionHandler;
public class DelegateUsage {
public static void main(String[] args) {
// legacy
// SessionHandler sessionHandler = new SessionHandler(new JdbcSessionRegistry());
// new
RedisSessionClient adaptee = new RedisSessionClient();
ClientRegistryAdapter adapter = new ClientRegistryAdapter(adaptee);
SessionHandler sessionHandler = new SessionHandler(adapter);
sessionHandler.getSession("J12345");
}
}
변경된 클래스 다이어그램
3. Adapter pattern in Spring
Spring 프레임워크에서 어댑터 패턴이 적용된 케이스를 찾아보았습니다.
3.1. GsonBuilderUtils 클래스
- 클래스 내부에
Base64TypeAdapter가 존재합니다. - 클라이언트는
Gson클래스입니다.GsonBuilder클래스는Gson객체를 만들 때 바이트 배열 (역)직렬화를 위한 어댑터를 주입할 것으로 예상됩니다.Gson객체는 어댑터 클래스를 이용해 바이트 배열 자료형에 대한 (역)직렬화 처리를 수행합니다.
- 대상 인터페이스는
JsonSerializer입니다.serialize기능과deserialize기능을 새로운 기능으로 변경합니다.
- 어댑티 클래스는
Base64Utils입니다.- 바이트 배열을 인코딩 된 문자열로 변경합니다.
- 인코딩 된 문자열을 바이트 배열로 변경합니다.
- 어댑터 클래스는
Base64TypeAdapter클래스입니다.- 바이트 배열에 대한
Json직렬화, 역직렬화 기능을 새롭게 변경합니다. Base64Utils클래스에게 직렬화, 역질렬화 일을 위임합니다.
- 바이트 배열에 대한
package org.springframework.http.converter.json;
// import classes
public abstract class GsonBuilderUtils {
public GsonBuilderUtils() {
}
public static GsonBuilder gsonBuilderWithBase64EncodedByteArrays() {
GsonBuilder builder = new GsonBuilder();
builder.registerTypeHierarchyAdapter(byte[].class, new GsonBuilderUtils.Base64TypeAdapter());
return builder;
}
private static class Base64TypeAdapter implements JsonSerializer<byte[]>, Base64TypeAdapter<byte[]> {
private Base64TypeAdapter() {
}
public JsonElement serialize(byte[] src, Type typeOfSrc, JsonSerializationContext context) {
return new JsonPrimitive(Base64Utils.encodeToString(src));
}
public byte[] deserialize(JsonElement json, Type type, JsonDeserializationContext cxt) {
return Base64Utils.decodeFromString(json.getAsString());
}
}
}
3.2. RsaKeyConversionServicePostProcessor 클래스
- 내부적으로 두 개의 어댑터가 사용됩니다.
ResourceKeyConverterAdapter클래스- 클라이언트는 프레임워크 내부에서
convet메소드를 호출하는 클래스입니다. - 대상 인터페이스는
Converter이며,convert기능을 새로운 기능으로 변경합니다. - 어댑티는
Converter인스턴스입니다.this.pemInputStreamConverter().andThen(this.autoclose(delegate))메소드 호출을 통해 생성됩니다.
- 클라이언트는 프레임워크 내부에서
ConverterPropertyEditorAdapter클래스- 클라이언트는 프레임워크 내부에서
getAsText,setAsText메소드를 호출하는 클래스입니다. - 대상은
PropertyEditorSupport클래스이며,getAsText,setAsText기능을 새로운 기능으로 변경합니다. - 어댑티는
ResourceKeyConverterAdapter어댑터 인스턴스입니다.
- 클라이언트는 프레임워크 내부에서
package org.springframework.security.config.crypto;
// import classes
public class RsaKeyConversionServicePostProcessor implements BeanFactoryPostProcessor {
private static final String CONVERSION_SERVICE_BEAN_NAME = "conversionService";
private RsaKeyConversionServicePostProcessor.ResourceKeyConverterAdapter<RSAPublicKey> x509 = new RsaKeyConversionServicePostProcessor.ResourceKeyConverterAdapter(RsaKeyConverters.x509());
private RsaKeyConversionServicePostProcessor.ResourceKeyConverterAdapter<RSAPrivateKey> pkcs8 = new RsaKeyConversionServicePostProcessor.ResourceKeyConverterAdapter(RsaKeyConverters.pkcs8());
public RsaKeyConversionServicePostProcessor() {
}
public void setResourceLoader(ResourceLoader resourceLoader) {
Assert.notNull(resourceLoader, "resourceLoader cannot be null");
this.x509.setResourceLoader(resourceLoader);
this.pkcs8.setResourceLoader(resourceLoader);
}
public void postProcessBeanFactory(ConfigurableListableBeanFactory beanFactory) throws BeansException {
if (!this.hasUserDefinedConversionService(beanFactory)) {
ConversionService service = beanFactory.getConversionService();
if (service instanceof ConverterRegistry) {
ConverterRegistry registry = (ConverterRegistry)service;
registry.addConverter(String.class, RSAPrivateKey.class, this.pkcs8);
registry.addConverter(String.class, RSAPublicKey.class, this.x509);
} else {
beanFactory.addPropertyEditorRegistrar((registryx) -> {
registryx.registerCustomEditor(RSAPublicKey.class, new RsaKeyConversionServicePostProcessor.ConverterPropertyEditorAdapter(this.x509));
registryx.registerCustomEditor(RSAPrivateKey.class, new RsaKeyConversionServicePostProcessor.ConverterPropertyEditorAdapter(this.pkcs8));
});
}
}
}
private boolean hasUserDefinedConversionService(ConfigurableListableBeanFactory beanFactory) {
return beanFactory.containsBean("conversionService") && beanFactory.isTypeMatch("conversionService", ConversionService.class);
}
static class ResourceKeyConverterAdapter<T extends Key> implements Converter<String, T> {
private ResourceLoader resourceLoader = new DefaultResourceLoader();
private final Converter<String, T> delegate;
ResourceKeyConverterAdapter(Converter<InputStream, T> delegate) {
this.delegate = this.pemInputStreamConverter().andThen(this.autoclose(delegate));
}
public T convert(String source) {
return (Key)this.delegate.convert(source);
}
void setResourceLoader(ResourceLoader resourceLoader) {
Assert.notNull(resourceLoader, "resourceLoader cannot be null");
this.resourceLoader = resourceLoader;
}
private Converter<String, InputStream> pemInputStreamConverter() {
return (source) -> {
return source.startsWith("-----") ? this.toInputStream(source) : this.toInputStream(this.resourceLoader.getResource(source));
};
}
private InputStream toInputStream(String raw) {
return new ByteArrayInputStream(raw.getBytes(StandardCharsets.UTF_8));
}
private InputStream toInputStream(Resource resource) {
try {
return resource.getInputStream();
} catch (IOException var3) {
throw new UncheckedIOException(var3);
}
}
private <T> Converter<InputStream, T> autoclose(Converter<InputStream, T> inputStreamKeyConverter) {
return (inputStream) -> {
try {
InputStream is = inputStream;
Object var3;
try {
var3 = inputStreamKeyConverter.convert(is);
} catch (Throwable var6) {
if (inputStream != null) {
try {
is.close();
} catch (Throwable var5) {
var6.addSuppressed(var5);
}
}
throw var6;
}
if (inputStream != null) {
inputStream.close();
}
return var3;
} catch (IOException var7) {
throw new UncheckedIOException(var7);
}
};
}
}
private static class ConverterPropertyEditorAdapter<T> extends PropertyEditorSupport {
private final Converter<String, T> converter;
ConverterPropertyEditorAdapter(Converter<String, T> converter) {
this.converter = converter;
}
public String getAsText() {
return null;
}
public void setAsText(String text) throws IllegalArgumentException {
if (StringUtils.hasText(text)) {
this.setValue(this.converter.convert(text));
} else {
this.setValue((Object)null);
}
}
}
}
댓글남기기