Prism은 어떻게 View상호작용 view를 호출하는가
기본적인 WPF의 경우
window에서 다른 usercontrol을 출현시키기 위해서는 해당 usercontrol을 알고 있어야 했다.
그것을 prism에서 어떻게 분리하였는지 확인해본다.
https://github.com/2Bbear/WindowsProgrmaDevelop/tree/master/WPF/UsingMvvmPrismLibrary/05-ViewInjection
참고는 이곳에서 하면 된다
1 2 3 4 5 6 7 8 9 10 11 12 | public partial class App : PrismApplication { protected override Window CreateShell() { return Container.Resolve<MainWindow>(); } protected override void RegisterTypes(IContainerRegistry containerRegistry) { } } | cs |
app에서 시작 윈도우로 MainWindow를 지정해 놓았다.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 | public partial class MainWindow : Window { IContainerExtension _container; IRegionManager _regionManager; public MainWindow(IContainerExtension container, IRegionManager regionManager) { InitializeComponent(); _container = container; _regionManager = regionManager; } /* 어차피 regionmanager에 등록하는 과정이다. 바로 registerviewwithregion으로 하나 분리하여 등록 명 따로 붙일 view따로 하나 하는 행동은 같은 것이다. */ private void Button_Click(object sender, RoutedEventArgs e) { var view = _container.Resolve<ViewA>(); _regionManager.RegisterViewWithRegion("ContentRegion", typeof(ViewA)); //IRegion region = _regionManager.Regions["ContentRegion"]; //region.Add(view); } } | cs |
Main윈도우를 확인하면 IContainerExtension 과 IregionManager가 멤버 변수로 되어 있는데 이는 생성자에서 받을 수 있는 현재 retion manager와 container를 저장하고 있기 위함이다.
이후 Button_Click메소드가
1 2 3 4 5 6 7 8 9 10 11 | <Window x:Class="ViewInjection.Views.MainWindow" xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:prism="http://prismlibrary.com/" Title="Shell" Height="350" Width="525"> <DockPanel LastChildFill="True"> <Button DockPanel.Dock="Top" Click="Button_Click">Add View</Button> <ContentControl prism:RegionManager.RegionName="ContentRegion" /> </DockPanel> </Window> | cs |
mainwindow xaml에서 이렇게 붙어있게된다.
이후 컴파일시에는 ContentRegion이라는 것이 무엇인지 몰라 출력하지 않고 있다가
런타임에서 버튼 클릭시 해당 view를 regionmanager에 등록시키는 과정을 진행하여 런타임으로 붙을 수 있게 한다.
'중단한 프로젝트 > WPF_PrismLibrary(추후진행)' 카테고리의 다른 글
| Prism은 어떻게 모듈을 관리하는가 (0) | 2019.02.19 |
|---|---|
| Prism은 어떻게 View를 다른 View로 변경하는가 (0) | 2019.02.19 |
| Prism은 어떻게 View에서 View를 호출하는가 - ViewDiscovery (0) | 2019.02.19 |
| Region이란 무엇인가 (0) | 2019.02.19 |
| Prism의 구성 Bootstrapper 와 Shell (0) | 2019.02.19 |
Prism은 어떻게 View에서 View를 호출하는가 - ViewDiscovery
이 내용은 ViewDiscovery에 대한 내용이다.
https://github.com/2Bbear/WindowsProgrmaDevelop/tree/master/WPF/UsingMvvmPrismLibrary/04-ViewDiscovery
참조는 04번 항목을 참조하면 된다.
1 2 3 4 5 6 7 8 9 10 11 12 | public partial class App : PrismApplication { protected override Window CreateShell() { return Container.Resolve<MainWindow>(); } protected override void RegisterTypes(IContainerRegistry containerRegistry) { } } | cs |
app 부분을 보면 시작 화면으로 MainWindow로 해놓았다.
1 2 3 4 5 6 7 8 9 | public partial class MainWindow : Window { public MainWindow(IRegionManager regionManager) { InitializeComponent(); //view discovery regionManager.RegisterViewWithRegion("ContentRegion", typeof(ViewA)); regionManager.RegisterViewWithRegion("ContentRegion_Main",typeof(MyView)); } } | cs |
MainWindow 생성자를 확인하면 매개변수로 IRegionManager를 받고있다.
이 RegionManager로 모든 View를 관리 할 수 있게 된다.
여기서 regionManger는 응용프로그램 생성 초기 단계에서 만들어진 객체이다.
이제 이 regionManger에 View를 등록해야한다. (등록 이름, 등록할 타입view)
이후
xaml에서는 이 등록 이름으로 각 view를 호출 할 수 있게 된다.
1 2 3 4 5 6 7 8 9 10 11 | <Window x:Class="ViewDiscovery.Views.MainWindow" xmlns="http://schemas.microsoft.com/winfx/2006/xaml/presentation" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:prism="http://prismlibrary.com/" Title="Shell" Height="350" Width="525"> <Grid> <ContentControl prism:RegionManager.RegionName="ContentRegion" /> <ContentControl prism:RegionManager.RegionName="ContentRegion_Main" /> </Grid> </Window> | cs |
이런 식으로 만들어 View가 직접적으로 View를 참조하지 못하게만들어 느슨하게 개발 할 수 있게되는 것이다... 호오.
'중단한 프로젝트 > WPF_PrismLibrary(추후진행)' 카테고리의 다른 글
| Prism은 어떻게 모듈을 관리하는가 (0) | 2019.02.19 |
|---|---|
| Prism은 어떻게 View를 다른 View로 변경하는가 (0) | 2019.02.19 |
| Prism은 어떻게 View상호작용 view를 호출하는가 (0) | 2019.02.19 |
| Region이란 무엇인가 (0) | 2019.02.19 |
| Prism의 구성 Bootstrapper 와 Shell (0) | 2019.02.19 |
Region이란 무엇인가
Region의 생성 순서
https://github.com/2Bbear/WindowsProgrmaDevelop/tree/master/WPF/UsingMvvmPrismLibrary/03-CustomRegions
참조 코드
App RegisterTypes -> App ConfigureRegionAdapterMappings -> StackPanelIRegionAdapter 생성자-> ...
전편의 부트스트랩 생성과정.
두 사진을 비교해서 각 과정을 살펴보면
응용프로그램이 생성되면서 리전이 이미 만들어져있음을 확인 할 수 있다.
'중단한 프로젝트 > WPF_PrismLibrary(추후진행)' 카테고리의 다른 글
| Prism은 어떻게 모듈을 관리하는가 (0) | 2019.02.19 |
|---|---|
| Prism은 어떻게 View를 다른 View로 변경하는가 (0) | 2019.02.19 |
| Prism은 어떻게 View상호작용 view를 호출하는가 (0) | 2019.02.19 |
| Prism은 어떻게 View에서 View를 호출하는가 - ViewDiscovery (0) | 2019.02.19 |
| Prism의 구성 Bootstrapper 와 Shell (0) | 2019.02.19 |
Prism의 구성 Bootstrapper 와 Shell
프리즘의 기본적인 구조
왼편이 개발자가 구현해야하는 부분이고 오른쪽은 Prism이 제공해 놓은 기능이다.
사실 이 구조를 기억한다고 해서 도움이 될 것 같진 않다.
Prism의 모든 이해의 시작은 시작점인 Bootstrapper에서 부터 시작되어야 한다.
1. Bootstrapper
공식 부트스트래퍼 소개내용 : 부트스트래퍼는 Prism 라이브러리를 사용하여 구축된 응용프로그램의 "초기화" 를 담당하고 있는 클래스이다.
즉 Prism으로 만들어진 응용프로그램에서는 Bootstrapper로만 Prism의 기능을 초기화 할때 안전하게 초기화 할 수 있다는 것을 알 수 있다.
부트스트래핑 절차의 기본 단계.
실제로 부트스트래퍼가 실행되는 과정을 로그로 추적하면 이렇게 나온다.
해당 소스코드 : https://github.com/2Bbear/WindowsProgrmaDevelop/tree/master/WPF/UsingMvvmPrismLibrary/PrismLibraryStudyBootStrap
App OnStartUp-> MyBootstrapper createshell -> MainWindow 생성자 -> MyBootstrapper InitializeShell -> App OnStartUp종료
이렇듯. 기존 WPF의 스타트업 구조 사이에 부트스트랩이 끼어듬으로써 MainWindow를 시작하고 있음을 확인 할 수 있다.
2. Shell
특히 Bootstrapper를 상속받은 MyBootstrapper에는 CreateShell이라는 메소드를 오버라이드하고 있는데 이곳에서 return형으로 컨테이너형태에 담고 있는 객체의 형태로 MainWindow의 형태를 갖고 있다.
즉 시작 윈도우를 설정하고 있는 것이다.
기존의 WPF에서는 Uniform Resource Identifiuer라는 URI로 주 화면을 실행하는 코드가 App.xaml에 있었는데 그 코드가 사라지고 부트스트래퍼 CreateShell로 넘어온 것이다.
공식 홈페이지 영어 해석:
Prism 라이브러리로 만든 응용프로그램에서 쉘과 주 화면을 만드는 것은 부트스트래퍼의 책임이다.
쉘은 쉘이 표시되기 전에 등록되어야 하는데 Region Manager같은 서비스에 의존하고 있다.
본문 해석에서 확인 할 수 있듯이 CreateShell이라는 것은 Shell을 만들고 그것을 어딘가에 등록하고 있다. 그 대상에 바로 Region Manager라는 곳이다.
1번 단락의 로그 사진을 다시 살펴보면
App 시작 -> 모듈카테고리 생성 -> 모듈카테고리 환경설정 -> 유니티 컨테이너 생성 -> 유니티 컨테이너 환경설정
-> 컨테이너에 부트스트래퍼 확장 붙이기 -> 서비스로케이션 싱글톤 환경설정 -> 유니티에 사용된 컨테이너 로케이터 환경설정
-> region 어뎁터 환경설정-> 기본 region 행동 환경설정 -> 프레임워크 예외형태 등록
-> Shell 생성 -> Bootstrapper CreateShell 실행 -> MainWindow생성자 실행 -> Region Manager 세팅 -> Region 업데이트
-> Shell 초기화 -> Bootstrapper InitializeShell 실행 -> 모듈 초기화 -> Bootstrapper 시퀸스(흐름) 종료
이런식으로 실행이 되는데 Create Shell을 실행하면서 Region Manager를 호출하는 모습을 확인 할 수 있다.
즉 Shell이 생성되기 이전에 Region Manager가 존재함을 알 수 있다.
여기서 Region Manager에 Shell 붙어있는지 장담을 할 수는 없는데. 아직 코드를 보지 못하였기 때문이다.
아무튼 이렇게 Bootstrapper를 이용하여 응용프로그램을 초기화 하면서 고려해야 할 것들이
- DI 컨테이너를 위해서 MEF, Unity 혹은 또다른 컨테이너를 사용할지 결정해야 한다. 이것은 당신이 사용할 부트스래퍼가 어떤 것이며 당신이 다른 컨테이너에 대해 부트스트래퍼 작성여부를 결정하게 될 것이다.
- 응용프로그램에서 당신이 원하는 응용프로그램의 특정 서비스에 대해 고려해 보아야한다. 즉 고려한 특정 서비스를 컨테이너에 등록해야 하기 때문이다.
- 내장 로깅 서비스가 당신에게 필요한지, 아니면 다른 로깅 서비스를 이용 해야 할지 결정 할 수 있다.
- 응용프로그램이 어떻게 모듈을 탐색할지 결정할 수 있다.
3. Custom Bootstrapper 만들기
https://github.com/PrismLibrary/Prism-Samples-Wpf/tree/master/01-BootstrapperShell
기본적인 예제는 이곳을 참조하는 것이 좋다.
내부적인 구성은
https://pirtaja.tistory.com/entry/Prism-2-Initializing-Applications-Using-the-Prism-Library-50-for-WPF
이곳을 참조하는 것이 좋다.
'중단한 프로젝트 > WPF_PrismLibrary(추후진행)' 카테고리의 다른 글
| Prism은 어떻게 모듈을 관리하는가 (0) | 2019.02.19 |
|---|---|
| Prism은 어떻게 View를 다른 View로 변경하는가 (0) | 2019.02.19 |
| Prism은 어떻게 View상호작용 view를 호출하는가 (0) | 2019.02.19 |
| Prism은 어떻게 View에서 View를 호출하는가 - ViewDiscovery (0) | 2019.02.19 |
| Region이란 무엇인가 (0) | 2019.02.19 |
9. 서버 어플리케이션 서비스에 DBConnectionPool을 만들자
이 포스팅은 오라클 DB, 자바 스프링을 이용합니다.
============================================================
왜 DBConnectionPool을 사용해야 하는가
참고 : https://all-record.tistory.com/104
단일 DBConnection을 이용하여 DB 연결을 시도할 경우 동시 다량의 Request 요청에 응답 하지 못할 수가 있다.
따라서 일정한 간격으로 응답하거나 안정적인 응답을 해주기 위하여 DBCP를 만들게 되는데.
가장 큰 요점은 미리 Connection객체를 만들어 놔서 매번 만들어 쓰지 말고 돌려쓰자는 개념이다. 따라서 최소 Connection 객체 수와 최대 Connection 객체 수가 정해져야하는데 이 범위는 각 프로그램의 성능과 하드웨어적 요인과 더불어 프로그래머가 적절히 선택해야 한다고 생각한다.
1. 아파치 Commons dbcp2를 다운 받는다.
참고 : https://www.baeldung.com/java-connection-pooling
이후 다운 받은 jar을 이클립스 프로젝트 라이브러리에 추가시킨다.
2. 코드 작성
HomeController
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262 263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295 296 297 298 | package com.company.jjh; import static org.junit.Assert.assertTrue; import java.io.IOException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.text.DateFormat; import java.util.Date; import java.util.Locale; import java.util.Vector; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import com.company.db.DBConnection; import com.company.db.BasicConnectionPool; import com.company.db.ConnectionPool; import com.company.jjh.*; /** * Handles requests for the application home page. */ @Controller public class HomeController { private ConnectionPool connectionPool=null; // //byte로 처리 private int callCount=0; // private static final Logger logger = LoggerFactory.getLogger(HomeController.class); HomeController(){ try { connectionPool=BasicConnectionPool.create("jdbc:oracle:thin:@localhost:1521:orcl", "scott", "0000"); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } @RequestMapping(value = "/", method = RequestMethod.GET) public void home(HttpServletRequest request,HttpServletResponse response) throws IOException { System.out.println("test : 누가 root에 접속했습니다"); response.getWriter().append("test Served at: ").append(request.getContextPath()); System.out.println(response); } @RequestMapping(value = "/Login", method = RequestMethod.GET) public void Process_LogIn(HttpServletRequest request,HttpServletResponse response) throws IOException { System.out.println("test: 누가 login에 접속했습니다"); response.getWriter().append("test Served at Login: "); } @RequestMapping(value = "/TestDB/getEmpTable", method = RequestMethod.GET) public void Process_TestDBGetEmpTable(HttpServletRequest request,HttpServletResponse response) throws IOException { System.out.println("test: DB test GetEmpTalbe이 실행되었습니다"); response.getWriter().append("call count="+callCount+" test Served at TestDBGetEmpTable: "); for(String t : CallDBConnectionPool() ) { response.getWriter().append("<p>"+t+"</p>"); } callCount++; } @RequestMapping(value = "/TestDB/getEmpTable2", method = RequestMethod.GET) public void Process_TestDBGetEmpTable2(HttpServletRequest request,HttpServletResponse response) throws IOException { //System.out.println("test: DB test GetEmpTalbe이 실행되었습니다"); response.getWriter().append(" test Served at TestDBGetEmpTable: "); for(String t : CallDBConnectionPoolNotPrint() ) { response.getWriter().append("<p>"+t+"</p>"); } } @RequestMapping(value = "/TestAppService/getValue", method = RequestMethod.GET) public void Process_TestAppServiceGetValue(HttpServletRequest request,HttpServletResponse response) throws IOException { System.out.println("test: TestAppServiceGetValue이 실행되었습니다"); response.getWriter().append("call count="+callCount+" test Served at TestDBGetEmpTable: "); callCount++; } Vector<String> CallDBConnectionPoolNotPrint() { Connection conn = null; // DB연결된 상태(세션)을 담은 객체 PreparedStatement pstm = null; // SQL 문을 나타내는 객체 ResultSet rs = null; // 쿼리문을 날린것에 대한 반환값을 담을 객체 Vector<String> function_result=new Vector<String>(); try { // SQL 문장을 만들고 만약 문장이 질의어(SELECT문)라면 // 그 결과를 담을 ResulSet 객체를 준비한 후 실행시킨다. String quary = "SELECT * FROM EMP"; conn =connectionPool.getConnection(); pstm = conn.prepareStatement(quary); rs = pstm.executeQuery(); /* EMP 테이블의 데이터 타입 * EMPNO NOT NULL NUMBER(4) -- int ENAME VARCHAR2(10) -- String JOB VARCHAR2(9) -- String MGR NUMBER(4) -- int HIREDATE DATE -- Date SAL NUMBER(7,2) -- float/double COMM NUMBER(7,2) -- float/double DEPTNO NUMBER(2) -- int */ //System.out.println("EMPNO ENAME JOB MGR HIREDATE SAL COMM DEPTNO"); //System.out.println("============================================"); while(rs.next()){ int empno = rs.getInt(1); //int empno = rs.getInt("empno"); 숫자 대신 컬럼 이름을 적어도 된다. String ename = rs.getString(2); String job = rs.getString(3); int mgr = rs.getInt(4); java.sql.Date hiredate = rs.getDate(5); // Date 타입 처리 int sal = rs.getInt(6); int comm = rs.getInt(7); int deptno = rs.getInt(8); String result = empno+" "+ename+" "+job+" "+mgr+" "+hiredate+" "+sal+" "+comm+" "+deptno; //System.out.println(result); function_result.add(result); } } catch (SQLException sqle) { System.out.println("SELECT문에서 예외 발생"); sqle.printStackTrace(); }finally{ // DB 연결을 종료한다. try{ if ( rs != null ){rs.close();} if ( pstm != null ){pstm.close();} if ( conn != null ){connectionPool.releaseConnection(conn); } }catch(Exception e){ throw new RuntimeException(e.getMessage()); } } return function_result; } Vector<String> CallDBConnectionPool() { Connection conn = null; // DB연결된 상태(세션)을 담은 객체 PreparedStatement pstm = null; // SQL 문을 나타내는 객체 ResultSet rs = null; // 쿼리문을 날린것에 대한 반환값을 담을 객체 Vector<String> function_result=new Vector<String>(); try { // SQL 문장을 만들고 만약 문장이 질의어(SELECT문)라면 // 그 결과를 담을 ResulSet 객체를 준비한 후 실행시킨다. String quary = "SELECT * FROM EMP"; conn =connectionPool.getConnection(); pstm = conn.prepareStatement(quary); rs = pstm.executeQuery(); /* EMP 테이블의 데이터 타입 * EMPNO NOT NULL NUMBER(4) -- int ENAME VARCHAR2(10) -- String JOB VARCHAR2(9) -- String MGR NUMBER(4) -- int HIREDATE DATE -- Date SAL NUMBER(7,2) -- float/double COMM NUMBER(7,2) -- float/double DEPTNO NUMBER(2) -- int */ System.out.println("EMPNO ENAME JOB MGR HIREDATE SAL COMM DEPTNO"); System.out.println("============================================"); while(rs.next()){ int empno = rs.getInt(1); //int empno = rs.getInt("empno"); 숫자 대신 컬럼 이름을 적어도 된다. String ename = rs.getString(2); String job = rs.getString(3); int mgr = rs.getInt(4); java.sql.Date hiredate = rs.getDate(5); // Date 타입 처리 int sal = rs.getInt(6); int comm = rs.getInt(7); int deptno = rs.getInt(8); String result = empno+" "+ename+" "+job+" "+mgr+" "+hiredate+" "+sal+" "+comm+" "+deptno; System.out.println(result); function_result.add(result); } } catch (SQLException sqle) { System.out.println("SELECT문에서 예외 발생"); sqle.printStackTrace(); }finally{ // DB 연결을 종료한다. try{ if ( rs != null ){rs.close();} if ( pstm != null ){pstm.close();} if ( conn != null ){connectionPool.releaseConnection(conn); } }catch(Exception e){ throw new RuntimeException(e.getMessage()); } } return function_result; } Vector<String> CallDBConnection() { Connection conn = null; // DB연결된 상태(세션)을 담은 객체 PreparedStatement pstm = null; // SQL 문을 나타내는 객체 ResultSet rs = null; // 쿼리문을 날린것에 대한 반환값을 담을 객체 Vector<String> function_result=new Vector<String>(); try { // SQL 문장을 만들고 만약 문장이 질의어(SELECT문)라면 // 그 결과를 담을 ResulSet 객체를 준비한 후 실행시킨다. String quary = "SELECT * FROM EMP"; conn = DBConnection.getConnection(); pstm = conn.prepareStatement(quary); rs = pstm.executeQuery(); /* EMP 테이블의 데이터 타입 * EMPNO NOT NULL NUMBER(4) -- int ENAME VARCHAR2(10) -- String JOB VARCHAR2(9) -- String MGR NUMBER(4) -- int HIREDATE DATE -- Date SAL NUMBER(7,2) -- float/double COMM NUMBER(7,2) -- float/double DEPTNO NUMBER(2) -- int */ System.out.println("EMPNO ENAME JOB MGR HIREDATE SAL COMM DEPTNO"); System.out.println("============================================"); while(rs.next()){ int empno = rs.getInt(1); //int empno = rs.getInt("empno"); 숫자 대신 컬럼 이름을 적어도 된다. String ename = rs.getString(2); String job = rs.getString(3); int mgr = rs.getInt(4); java.sql.Date hiredate = rs.getDate(5); // Date 타입 처리 int sal = rs.getInt(6); int comm = rs.getInt(7); int deptno = rs.getInt(8); String result = empno+" "+ename+" "+job+" "+mgr+" "+hiredate+" "+sal+" "+comm+" "+deptno; System.out.println(result); function_result.add(result); } } catch (SQLException sqle) { System.out.println("SELECT문에서 예외 발생"); sqle.printStackTrace(); }finally{ // DB 연결을 종료한다. try{ if ( rs != null ){rs.close();} if ( pstm != null ){pstm.close();} if ( conn != null ){conn.close(); } }catch(Exception e){ throw new RuntimeException(e.getMessage()); } } return function_result; } } | cs |
ConnectionPool interface 작성
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 | package com.company.db; import java.sql.Connection; import java.sql.SQLException; import java.util.List; public interface ConnectionPool { Connection getConnection() throws SQLException; boolean releaseConnection(Connection connection); String getUrl(); String getUser(); String getPassword(); void shutdown() throws SQLException; List<Connection> getConnectionPool(); } | cs |
BasicConnectionPool 클래스 작성
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 | package com.company.db; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; public class BasicConnectionPool implements ConnectionPool { private final String url; private final String user; private final String password; private final List<Connection> connectionPool; private final List<Connection> usedConnections = new ArrayList<>(); private static final int INITIAL_POOL_SIZE = 10; private final int MAX_POOL_SIZE = 50; public static BasicConnectionPool create(String url, String user, String password) throws SQLException { List<Connection> pool = new ArrayList<>(INITIAL_POOL_SIZE); for (int i = 0; i < INITIAL_POOL_SIZE; i++) { pool.add(createConnection(url, user, password)); } return new BasicConnectionPool(url, user, password, pool); } private BasicConnectionPool(String url, String user, String password, List<Connection> connectionPool) { this.url = url; this.user = user; this.password = password; this.connectionPool = connectionPool; } @Override public Connection getConnection() throws SQLException { if (connectionPool.isEmpty()) { if (usedConnections.size() < MAX_POOL_SIZE) { connectionPool.add(createConnection(url, user, password)); } else { throw new RuntimeException("Maximum pool size reached, no available connections!"); } } Connection connection = connectionPool.remove(connectionPool.size() - 1); usedConnections.add(connection); return connection; } @Override public boolean releaseConnection(Connection connection) { connectionPool.add(connection); return usedConnections.remove(connection); } private static Connection createConnection(String url, String user, String password) throws SQLException { return DriverManager.getConnection(url, user, password); } public int getSize() { return connectionPool.size() + usedConnections.size(); } public List<Connection> getConnectionPool() { return connectionPool; } @Override public String getUrl() { return url; } @Override public String getUser() { return user; } @Override public String getPassword() { return password; } public void shutdown() throws SQLException { usedConnections.forEach(this::releaseConnection); for (Connection c : connectionPool) { c.close(); } connectionPool.clear(); } } | cs |
3. 코드 설명
해당 코드는 jdk 1.8에서 작동하며 프로젝트가 jdk버전에 맞지 않으면 오류가 발생 할 수 있다.
DBCP는 BasicConnectionPool 로서, 해당 객체를 이용하여 Connection 객체들을 관리한다.
때문에 HomeController는 해당 BasicConnectionPool을 이용하여 DB에 접속한다.
특이하게 static으로 만들어진 이 DBCP 클래스는 생성조차 범상치 않다...
connectionPool=BasicConnectionPool.create("jdbc:oracle:thin:@localhost:1521:orcl", "scott", "0000");
이런 식으로 만들어지는데. 나는 처음 보는 문법이므로 설명을 할 수가 없다.
다만 이해를 하자면 static으로 만들어진 블럭을 생성하는 문법으로 람다를 이용 한 것 처럼 보인다고 생각 할 뿐이다. 그러므로 매번 저 create를 사용 할 경우 원하는 db 연결로 변경 해 줄 수 있다고 생각한다.
커넥션 할당은 이렇게 하였고
conn =connectionPool.getConnection();
커넥셜 풀링은
if ( conn != null ){connectionPool.releaseConnection(conn); }
이렇게 해주었다. conn에 무언가 있을 경우 DBCP의 release 메소드를 호출하여 conn값을 넘기면 conn의 객체를 릴리즈 시켜준다.
===========================================================
이후는 단순히 성능 테스트 이므로 보지 않아도 무관하다.
1000회 DB 읽기 작업을 request 하여 걸린 시간
1회 초당 서버 어플리케이션 서비스에 있는 변수를 읽어들인 횟수
2회 초당 서버 어플리케이션 서비스에 있는 변수를 읽어들인 횟수
단순한 C++ 코드로 반복적인 성능 테스트를 한 결과
1. 일반 Connection 보다는 ConnectionPool이 안정적이고 속도는 2배 차이가 난다. 운영체제 HW에 따라 달라진다고 예상된다.
2. ConnectionPool의 max값은 일정 값 이상이 될 경우 속도의 차가 없으며 min값도 일정 값 이상이 될 경우 속도의 차가 없다.
3. 화면 출력 code를 제거시 속도 향상을 보인다.
outstream을 이용하지 않아 일어나는 현상이라 생각한다.
추가 적으로 DB에 접근하지 않고 즉 DBCP를 이용하지 않고 그냥 어플리케이션의 request 성능을 테스트 한결과
1. 초당 100~130 정도의 request 수행 능력을 보여주었다.HW와 OS에 따라 달라진다고 생각한다.
2. 역시 outstream을 이용하지 않을 경우 2초 이상 수행 시간이 단축되는 것을 확인 할 수 있었다.
'중단한 프로젝트 > WebServerGameProject(Team)' 카테고리의 다른 글
| 8. 스프링 웹 어플리케이션 서비스에 request하면 db에 접속하는 기능을 만들자 (0) | 2019.01.30 |
|---|---|
| 7. rest SDK를 이용하여 request해서 respon 된 값 출력하기 (0) | 2019.01.29 |
| 6. cpprest , rest 라이브러리로 C++로 http 통신 구하기 (0) | 2019.01.29 |
| 5. Boost asio를 이용한 네트워크 통신 만들어보기 (0) | 2019.01.28 |
| 4. c++로 webservice에 연결하는 방법 (0) | 2019.01.24 |
8. 스프링 웹 어플리케이션 서비스에 request하면 db에 접속하는 기능을 만들자
이 포스팅은
스프링 프로젝트, 오라클 DB를 이용하여 만들어집니다.
MySQL이나 다른 DB는 안쓰니 다른 정보를 검색해주세요.
추가로 마이바티스도 안쓰고 작성하는 겁니다. 마이바티스를 쓰는 걸 보고 싶으신 분은 구글에 검색해 보시면 됩니다.
============================================================
1. 이클립스로 스프링 프로젝트를 만듭니다
레그씨 프로직트를 만듭니다.
이후 MVC 형태의 스프링 프로젝트를 선택해주고
간단하게 패키지 명을 정해줍니다. 보통 com.company.자신이 원하는 이름
이런 식으로 만든다고 하네요
만들고 잠시 관련 라이브러리를 설치하는 것을 기다려 줍니다.
2. 오라클 jdbc 라이브러리를 가져옵시다.
C:\app\오라클 설치한 사용자 계정\product\11.2.0\dbhome_1\jdbc\lib
보통 이 경로상에 있으니 찾아보시면 됩니다
그 후 이렇게 이클립스 라이브러리에 추가해줍니다.
3. DB 연결을 위한 class를 만들어 줍니다.
package com.company.db;import java.sql.*;public class DBConnection {public static Connection dbConn;public static Connection getConnection() {Connection conn=null;try {String user="scott";String pw="0000";String url="jdbc:oracle:thin:@localhost:1521:orcl";Class.forName("oracle.jdbc.driver.OracleDriver");conn=DriverManager.getConnection(url, user, pw);System.out.println("Database에 연결되었습니다. \n");}catch (ClassNotFoundException cnfe) {System.out.println("DB 드라이버 로딩 실패 :"+cnfe.toString());} catch (SQLException sqle) {System.out.println("DB 접속실패 : "+sqle.toString());} catch (Exception e) {System.out.println("Unkonwn error");e.printStackTrace();}return conn;}}
4. 만들어진 스프링 HomeController에 이 클래스를 이용하여 코드를 작성합니다
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 | package com.company.jjh; import java.io.IOException; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.text.DateFormat; import java.util.Date; import java.util.Locale; import java.util.Vector; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Controller; import org.springframework.ui.Model; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import com.company.db.DBConnection; import com.company.jjh.*; /** * Handles requests for the application home page. */ @Controller public class HomeController { // //byte로 처리 private int callCount=0; // private static final Logger logger = LoggerFactory.getLogger(HomeController.class); @RequestMapping(value = "/", method = RequestMethod.GET) public void home(HttpServletRequest request,HttpServletResponse response) throws IOException { System.out.println("test : 누가 root에 접속했습니다"); response.getWriter().append("test Served at: ").append(request.getContextPath()); System.out.println(response); } @RequestMapping(value = "/Login", method = RequestMethod.GET) public void Process_LogIn(HttpServletRequest request,HttpServletResponse response) throws IOException { System.out.println("test: 누가 login에 접속했습니다"); response.getWriter().append("test Served at Login: "); } @RequestMapping(value = "/TestDB/getEmpTable", method = RequestMethod.GET) public void Process_TestDBGetEmpTable(HttpServletRequest request,HttpServletResponse response) throws IOException { System.out.println("test: DB test GetEmpTalbe이 실행되었습니다"); response.getWriter().append("call count="+callCount+" test Served at TestDBGetEmpTable: "); for(String t : CallDBConnection() ) { response.getWriter().append("<p>"+t+"</p>"); } callCount++; } Vector<String> CallDBConnection() { Connection conn = null; // DB연결된 상태(세션)을 담은 객체 PreparedStatement pstm = null; // SQL 문을 나타내는 객체 ResultSet rs = null; // 쿼리문을 날린것에 대한 반환값을 담을 객체 Vector<String> function_result=new Vector<String>(); try { // SQL 문장을 만들고 만약 문장이 질의어(SELECT문)라면 // 그 결과를 담을 ResulSet 객체를 준비한 후 실행시킨다. String quary = "SELECT * FROM EMP"; conn = DBConnection.getConnection(); pstm = conn.prepareStatement(quary); rs = pstm.executeQuery(); /* EMP 테이블의 데이터 타입 * EMPNO NOT NULL NUMBER(4) -- int ENAME VARCHAR2(10) -- String JOB VARCHAR2(9) -- String MGR NUMBER(4) -- int HIREDATE DATE -- Date SAL NUMBER(7,2) -- float/double COMM NUMBER(7,2) -- float/double DEPTNO NUMBER(2) -- int */ System.out.println("EMPNO ENAME JOB MGR HIREDATE SAL COMM DEPTNO"); System.out.println("============================================"); while(rs.next()){ int empno = rs.getInt(1); //int empno = rs.getInt("empno"); 숫자 대신 컬럼 이름을 적어도 된다. String ename = rs.getString(2); String job = rs.getString(3); int mgr = rs.getInt(4); java.sql.Date hiredate = rs.getDate(5); // Date 타입 처리 int sal = rs.getInt(6); int comm = rs.getInt(7); int deptno = rs.getInt(8); String result = empno+" "+ename+" "+job+" "+mgr+" "+hiredate+" "+sal+" "+comm+" "+deptno; System.out.println(result); function_result.add(result); } } catch (SQLException sqle) { System.out.println("SELECT문에서 예외 발생"); sqle.printStackTrace(); }finally{ // DB 연결을 종료한다. try{ if ( rs != null ){rs.close();} if ( pstm != null ){pstm.close();} if ( conn != null ){conn.close(); } }catch(Exception e){ throw new RuntimeException(e.getMessage()); } } return function_result; } } | cs |
5. 테스트 해봅시다 저는 C++로 respone 받은 데이터를 출력 시켜볼껍니다.
DB에서 잘 받아오는 것을 확인 할 수 있습니다.
'중단한 프로젝트 > WebServerGameProject(Team)' 카테고리의 다른 글
| 9. 서버 어플리케이션 서비스에 DBConnectionPool을 만들자 (0) | 2019.01.30 |
|---|---|
| 7. rest SDK를 이용하여 request해서 respon 된 값 출력하기 (0) | 2019.01.29 |
| 6. cpprest , rest 라이브러리로 C++로 http 통신 구하기 (0) | 2019.01.29 |
| 5. Boost asio를 이용한 네트워크 통신 만들어보기 (0) | 2019.01.28 |
| 4. c++로 webservice에 연결하는 방법 (0) | 2019.01.24 |
기존에 했었던 rest SDK 예제 코드를 이용하여 수정하였다.
============================================================
이번에는 respon된 값을 파일로 출력하는 것이 아닌 string으로 출력한다.
#include <cpprest/http_client.h> #include <cpprest/filestream.h> using namespace utility; using namespace web; using namespace web::http; using namespace web::http::client; using namespace concurrency::streams; int main() { pplx::task<void> requestTask2{ []() { std::cout << "1" << std::endl; http_client_config conf; conf.set_timeout(seconds(5)); http_client client(U("http://localhost:8080")); uri_builder builder(U("/webgameserver/Login"));
http_response response = client.request(methods::GET, builder.to_string()).get();
std::cout << "2" << std::endl; printf("Receive response status code:%u\n", response.status_code()); char ch = 0; std::string str; ch = response.body().read().get(); while (ch != -1) { str.push_back(ch); ch = response.body().read().get(); } std::cout << "respone : " << str << std::endl; }}; try { requestTask2.wait(); } catch (const std::exception &e) { printf("Error exception:%s\n", e.what()); } result 0; } |
원하는 형태로 값이 출력된 것을 확인 할 수 있다.
'중단한 프로젝트 > WebServerGameProject(Team)' 카테고리의 다른 글
| 9. 서버 어플리케이션 서비스에 DBConnectionPool을 만들자 (0) | 2019.01.30 |
|---|---|
| 8. 스프링 웹 어플리케이션 서비스에 request하면 db에 접속하는 기능을 만들자 (0) | 2019.01.30 |
| 6. cpprest , rest 라이브러리로 C++로 http 통신 구하기 (0) | 2019.01.29 |
| 5. Boost asio를 이용한 네트워크 통신 만들어보기 (0) | 2019.01.28 |
| 4. c++로 webservice에 연결하는 방법 (0) | 2019.01.24 |
6. cpprest , rest 라이브러리로 C++로 http 통신 구하기
드디어 찾았다 흙흙...
============================================================
1. cpprestsdk 를 다운받기 위해 Window용 vcpkg를 다운 받아야합니다.
참고 : https://upglay.tistory.com/12
이 블로그를 따라서 vcpkg를 다운 받아 봅시다.
window 8,7,10 이상의 os가 필요하고
visual studio 2015, 2017이 필요합니다
Git을 설치해야합니다
Cmake를 설치해야합니다.
1. vcpkg 설치 (윈도우 기준)
https://upglay.tistory.com/12 로 들어가서 Zip 파일로 파일을 내려 받습니다.
2.C 드라이브에 vcpkg라는 폴더를 만들어 그 곳에 다운 받은 Zip압축을 풀어줍니다.
3. CMD 창으로 가서 c:\vcpkg\boostrap-vcpkg.bat를 치면 설치가 시작됩니다.
여기까지 됐으면 스탑.!
2. 이제 cpprestsdk라이브러리를 설치합시다.
참고 : https://github.com/Microsoft/cpprestsdk
1. CMD 창에서 vcpkg install cpprestsdk cpprestsdk:x64-windows 명령어를 칩니다.
2. 27분을 기다려줍니다.....설치하는게 너무 많....용량 9기가...
3. 설치가 다 되면 현재 켜진 모든 Visual Studio를 종료합니다.
4. 다시 CMD 창으로 돌아가서 vcpkg integrate install 명령어를 쳐줍니다.
이 명령어로 모든 Visual studio에 라이브러리가 통합됩니다. 한 마디로 굳이 링커 연결을 안해주어도 헤더파일을 끌어다 쓸 수 있따는 겁니다!!! 하와와와
3. Visual Studio에 새로운 c++ 프로젝트를 만들어서 코드를 테스트 해봅시다.
#include <cpprest/http_client.h> #include <cpprest/filestream.h> using namespace utility; using namespace web; using namespace web::http; using namespace web::http::client; using namespace concurrency::streams; int main() { auto fileStream = std::make_shared<ostream>(); pplx::task<void> requestTask = fstream::open_ostream(U("result.html")).then([=](ostream outFile) { *fileStream = outFile; http_client_config conf; conf.set_timeout(seconds(5)); http_client client(U("http://localhost:8080")); uri_builder builder(U("/webgameserver/Login")); builder.append_query(U("q"), U("Casablanca CodePlex")); return client.request(methods::GET, builder.to_string()); }).then([=](http_response response) { printf("Receive response status code:%u\n", response.status_code()); return response.body().read_to_end(fileStream->streambuf()); }).then([=](size_t nVal) { printf("Size is %u\n", nVal); return fileStream->close(); }); try { requestTask.wait(); } catch (const std::exception &e) { printf("Error exception:%s\n", e.what()); } return 0; }
|
이 코드가 하는 일이 뭐냐면...해당 포트와 패스로 접속해서 접속된 응답을 result.http로 바꾸는 코드입니다. 흠...고쳐야 할 부분이 많지만 일단 써봅시다.
client url 적는 부분에 호스트와 포트번호를 합쳐서 넣어줍니다.
그 뒤 builder에는 Path를 즉 경로를 넣어서 센드 해주면
짜잔 하고 완성됩니다.
애초에 궁금하다면 웹 어플리케이션 서비스에 해당 접속이 이루어지면 반응하게 끔 하시면 알기 쉬울꺼에요
Login에 요청을 보내자 반응하는 모습입니다.
=====================================================
헐 이렇게 어렵게 설치하는 것 보다 이미 있는 rest sdk를 쓰는 게 좋지 않았을까.?..
https://psychoria.tistory.com/211
이분이 사용하시는거 보니...ㅠㅠ
'중단한 프로젝트 > WebServerGameProject(Team)' 카테고리의 다른 글
| 8. 스프링 웹 어플리케이션 서비스에 request하면 db에 접속하는 기능을 만들자 (0) | 2019.01.30 |
|---|---|
| 7. rest SDK를 이용하여 request해서 respon 된 값 출력하기 (0) | 2019.01.29 |
| 5. Boost asio를 이용한 네트워크 통신 만들어보기 (0) | 2019.01.28 |
| 4. c++로 webservice에 연결하는 방법 (0) | 2019.01.24 |
| 3. 요구사항을 분석하자 (0) | 2019.01.22 |
