입력 스트림에서 off부터 시작하여, len개를 읽어 byte 배열에 저장, 읽은 갯수를 반환
void
close()
시스템의 자원을 반환하고 입력 스트림을 닫는다. (파일)
▶ read() 메소드
InputStream is = new FileInputStream("C:/test.jpg");
int readByte;
//모든 InputStream 하위 객체 read() : 읽은 내용이 없으면 -1 반환
while((readByte = is.read()) != -1){}
▶ 키보드에서 읽어오기 : System.in
package mymain.input;
import java.io.InputStream;
public class _01_KeyboardInputTest {
public static void main(String[] args) throws Exception {
int ch;
//키보드의 입력값을 받는 inputStream
//System객체 내에 포함관계로 inputStream이 생성되어 있는 상태
InputStream is = System.in;
System.out.println("종료하려면 [Ctrl+Z]");
while((ch = is.read()) != -1) {
System.out.printf("%c",ch);
}
}
▶ 파일에서 읽어오기 : FileInputStream("파일경로")
package mymain.input;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
public class _02_FileInputTest {
public static void main(String[] args) throws IOException {
InputStream is = new FileInputStream("src/mymain/input/_02_FileInputTest.java");
int ch;
while((ch = is.read())!=-1) {
System.out.printf("%c",ch);
}
is.close();
}
}
▶ 네트워크에서 읽어오기 : URL(String url) > openStream()
package mymain.input;
import java.io.IOException;
import java.io.InputStream;
import java.net.URL;
public class _03_NetWorkInputStream {
public static void main(String[] args) throws IOException {
URL url = new URL("https://www.naver.com");
InputStream is = url.openStream();
int ch;
while((ch = is.read())!=-1) {
System.out.printf("%c",ch);
}
}
}
(2) OutputStream 메서드
리턴타입
메소드
void
write()
출력 스트림으로 1byte씩 보낸다.
void
write(byte[] b)
출력 스트림에 byte[] b의 값을 보낸다.
void
write(byte[] b, int off, int len)
출력 스트림에 off부터 시작해서 len개 만큼 보낸다.
void
flush()
버퍼에 잔류하는 모든 바이트를 출력
void
close()
시스템의 자원을 반납하고 출력 스트림을 닫는다. (파일)
▶ read() 메소드
OutputStream os = new FileOutputStream("C:/test.txt");
byte[] data = "ABC".getBytes();
for(int i = 0; i < data.length; i++){
os.write(data[i]);
}
▶ 모니터로 출력하기 : System.out
package mymain.output;
import java.io.IOException;
import java.io.OutputStream;
public class _01_MonitorTest {
public static void main(String[] args) throws IOException {
OutputStream os = System.out;
//자바 -> 출력 스트림 -> 키보드버퍼로 문자를 전송
os.write(65);
String msg = "안녕";
byte[] msg_bytes = msg.getBytes();
os.write(msg_bytes);
int n = 1004;
String s = String.valueOf(n);
os.write(s.getBytes());
boolean bOk = true;
String b = String.valueOf(bOk);
os.write(b.getBytes());
//키보드 커퍼를 비우면서 콘솔로 전송
os.flush();
}
}
▶ 파일로 출력하기 : FileOutputStream("파일경로");
package mymain.output;
import java.io.FileOutputStream;
import java.io.OutputStream;
public class _02_FileOutTest {
public static void main(String[] args) throws Exception{
OutputStream os = new FileOutputStream("a.txt");
os.write('A');
String name = "홍길동";
byte[] sArr = name.getBytes();
os.write(sArr);
int n = 1994;
os.write(String.valueOf(n).getBytes());
os.flush();
os.close();
}
}
(3) 바이트 배열 단위로 읽어오기/보내기
가. InputStream/OutputStream의 read(byte[] b), write(byte[] b) 사용
package mymain.input;
import java.io.FileInputStream;
import java.io.InputStream;
public class _04_InputStream_Array {
public static void main(String[] args) throws Exception{
InputStream is = new FileInputStream("src/mymain/input/_04_InputStream_Array.java");
int readByteNo;
byte[] readBytes = new byte[8];
// is.read(readBytes, 1, 8); <- index 1부터 8개
readByteNo = is.read(readBytes);
for(int i = 0; i < readBytes.length; i++)
System.out.printf("%c",readBytes[i]);
is.close();
}
}
package mymain.output;
import java.io.FileOutputStream;
import java.io.OutputStream;
public class _03_OutputStream_Array {
public static void main(String[] args) throws Exception{
OutputStream os = new FileOutputStream("a2.txt");
byte[] output = "ABC".getBytes();
// os.write(output,1,2); /*: index1부터 2개*/
os.write(output);
os.close();
}
}
나. ByteArrayInputStream/ByteArrayOutputStream 객체 사용
package mymain.input;
import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.util.Arrays;
public class _04_InputStream_Array2 {
public static void main(String[] args) throws Exception{
byte[] inSrc = {0,1,3,4,5,6};
byte[] outSrc = null;
ByteArrayInputStream input = null;
ByteArrayOutputStream output = null;
input = new ByteArrayInputStream(inSrc);
output = new ByteArrayOutputStream();
int data = 0;
while((data = input.read()) != -1) {
output.write(data);
}
outSrc = output.toByteArray();
System.out.println("Input Source : "+Arrays.toString(inSrc));
System.out.println("Output Source : "+Arrays.toString(outSrc));
}
}
//객체 생성
InetAddress ip = InetAddres.getLocalHost();
//객체 이름, 주소 추출 : String으로 반환
String ipName = ip.getHostName();
String ipAddress = ip.getHostAddress();
[2] 도메인 이름으로 IP 주소 얻으려 할때
//도메인에서 단일 ip 주소 가져오기
InetAddress ip = InetAddress.getByName("www.naver.com");
//도메인에서 여러개의 ip주소 가져오기
InetAddress[] ipArr = InetAddress.getAllByName("www.naver.com");
package tcpProtocol;
import java.io.OutputStream;
import java.net.Socket;
public class BasicSend {
public static void main(String[] args) throws Exception{
//[1] 소켓을 연다.(연결할 서버소켓의 주소와 포트를 작성)
Socket socket = new Socket("localhost",50000);
OutputStream os = socket.getOutputStream();
for(int i = 1; i <= 3; i++) {
//[2] 소켓의 OutputStream을 통해 byte단위의 데이터를 전송한다.
String data = "데이터"+i;
os.write(data.getBytes("UTF-8"));
}
os.flush();
//[3] 소켓 연결 끊기
//socket.close(); --> 의도적인 종료 : -1 값을 전달한다.
socket.close();
}
}
[2] 수신 방법
package tcpProtocol;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class BasicAccept {
public static void main(String[] args) throws Exception{
//[1] 서버 소켓을 연다.
ServerSocket serverSocket = new ServerSocket(50000);
try {
//[2] 소켓을 연다.
Socket socket = serverSocket.accept();
InputStream is = socket.getInputStream();
//무한 루프로 수신 대기
System.out.println("[수신 데이터]");
while(true) {
//[3] InputStream을 통해 바이트단위 데이터를 가져온다.
byte[] byteArr = new byte[300]; //한글 3byte->100자씩 읽을 것
int len = is.read(byteArr);
if(len == -1) break;
String data = new String(byteArr,0,len,"UTF-8");
//[4] 수신 data 콘솔에 출력
System.out.println(data);
}
} catch (IOException e) {
System.out.println("[연결 종료]");
}
}
}
[연습 예제_1] TCP 1:1 전송방식으로 로컬컴퓨터에서 에코메시지 전달하기
<Client>
package tcpProtocol;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.OutputStream;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.*;
public class Client extends JFrame{
JTextArea textMonitor;
JTextField textInput;
JButton button;
Socket socket;
Client(){
/* Initial Window UI Design */
super("Chat for Client");
setLocation(300,300);
setVisible(true);
setDefaultCloseOperation(EXIT_ON_CLOSE);
init_UiDesign();
pack();
/* TCP Socket Communication */
init_buttonAction();
init_socket();
}//end Client()
/////////////////////////////////////////////////////
/* TCP Socket Communication Method */
private void init_buttonAction() {
button.addActionListener(new ActionListener() {
@Override
public void actionPerformed(ActionEvent e) {
String textMessage = String.format("[사용자] %s%n", textInput.getText().trim());
if(textMessage.isEmpty()) {
JOptionPane.showMessageDialog(textMonitor,"메세지를 입력하세요.");
return;
}else {
//textMonitor.append(textMessage);
echo_message();
textInput.setText("");
return;
}
}
});
}
private void init_socket() {
try {
socket = new Socket("localhost",50000);
} catch (UnknownHostException e) {
System.out.println("해당 호스트를 찾을 수 없습니다.");
} catch (IOException e) {
System.out.println("포트가 비정상적으로 닫혀있습니다.");
}
}
protected void echo_message() {
send_message();
receive_message();
}
private void send_message() {
//send Message to server
try {
OutputStream outStream = socket.getOutputStream();
String userMessage = String.format("[사용자] %s%n", textInput.getText().trim());
//append message to Monitor
textMonitor.append(userMessage);
outStream.write(userMessage.getBytes());
outStream.flush();
} catch (IOException e) {
System.out.println("전송에 오류가 발생했습니다.");
}
}
private void receive_message() {
//receive Message from server
try {
byte[] readBytes = new byte[300];
int readNum = socket.getInputStream().read(readBytes);
String echoedMessage = new String(readBytes,0,readNum);
//append message to Monitor
textMonitor.append(echoedMessage);
} catch (IOException e) {
System.out.println("수신에 오류가 발생했습니다.");
}
}
/* UI Design Method */
private void init_UiDesign() {
//textMonitor : where chat text reveals
textMonitor = new JTextArea();
textMonitor.setBackground(new Color(0x7BC4C4));
textMonitor.setEditable(false);
JScrollPane jsp = new JScrollPane(textMonitor);
textMonitor.setPreferredSize(new Dimension(300,200));
this.add(jsp);
//textInput : where user types texts & send
JPanel jpl = new JPanel(new BorderLayout());
textInput = new JTextField();
button = new JButton("전송");
jpl.add(textInput);
jpl.add(button,"East");
this.add(jpl,"South");
}
public static void main(String[] args) {
new Client();
}//end main
}
<Server>
package tcpProtocol;
import java.awt.*;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.IOException;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import javax.swing.*;
public class Server extends JFrame{
JTextArea textMonitor;
JTextField textInput;
JButton button;
ServerSocket serverSocket;
Socket socket;
Server(){
/* Initial Window UI Design */
super("Chat for Server");
setLocation(300,300);
setVisible(true);
setDefaultCloseOperation(EXIT_ON_CLOSE);
init_UiDesign();
pack();
/* TCP Socket Communication */
init_socket();
}//end Client()
/////////////////////////////////////////////////////
/* TCP Socket Communication Method */
private void init_socket() {
try {
serverSocket = new ServerSocket(50000);
socket = serverSocket.accept();
while(true) {
//receive Message from client
byte[] readBytes = new byte[300];
int readNum = socket.getInputStream().read(readBytes);
String[] userMessage = new String(readBytes,0,readNum).split("]");
//append message to Monitor
textMonitor.append(new String(readBytes,0,readNum));
//send Message to client
OutputStream outStream = socket.getOutputStream();
String echoedMessage = String.format("[에코]%s%n",userMessage[1]);
//append message to Monitor
textMonitor.append(echoedMessage);
outStream.write(echoedMessage.getBytes());
outStream.flush();
}
} catch (IOException e) {
JOptionPane.showMessageDialog(this, e.getMessage());
}
}
/* UI Design Method */
private void init_UiDesign() {
//textMonitor : where chat text reveals
textMonitor = new JTextArea();
textMonitor.setBackground(new Color(0x7BC4C4));
textMonitor.setEditable(false);
JScrollPane jsp = new JScrollPane(textMonitor);
textMonitor.setPreferredSize(new Dimension(300,200));
this.add(jsp);
//textInput : where user types texts & send
JPanel jpl = new JPanel(new BorderLayout());
textInput = new JTextField();
button = new JButton("전송");
jpl.add(textInput);
jpl.add(button,"East");
this.add(jpl,"South");
}
public static void main(String[] args) {
new Server();
}//end main
}
>>결과
8. UDP 소켓 프로그래밍
- UDP는 소포와 같이 서버소켓을 통한 연결 없이 수신, 송신만 가능한 형태이다.
- 통신 선로가 고정적이지 않음
- 데이터 손실이 발생 가능
- 대신 TCP보다는 빠르게 전송이 가능하다
이것이 자바다 참조
[1] 송신하는 법
//송신하는 법
//[1] DatagramSocket를 연다.
DatagramSocket datagramSocket = new DatagramSocket();
//만약, multi-cast방식으로 전달할 경우,
//MulticastSocket multicastSocket = new MulticastSocket();
InetAddress ia = InetAddress.getByName("localhost"); //수신되는 곳의 주소
//[2] 전달할 데이터를 패킷으로 패킹한다.
String data = "전달 데이터";
byte[] byteArr = data.getBytes("UTF-8"); //UTF-8방식으로 바이트 변환
DatagramPacket packet = new DatagramPacket(
byteArr, byteArr.length,ia,포트번호
);
//[3] DatagramSocket을 통해 패킷을 전송한다.(바이트단위로 전송된다)
datagramSocket.send(packet);
//[4] DatagramSocket을 닫아준다.
datagramSocket.close();
[2] 수신하는 법
//수신하는 법
//[1] DatagramSocket을 연다.
DatagramSocket datagramSocket = new DatagramSocket(포트번호);
//[2] 패킷을 받을 배열과 길이를 지정한다.
DatagramPacket datagramPacket = new DatagramPacket(받은 배열을 저장할 바이트 배열,배열의 길이);
//[3] 패킷을 받는다.
datagramSocket.receive(datagramPacket);
//[4] 소켓을 닫는다.
datagramSocket.close();
[연습 예제_간단한 데이터 송수신]
<Client>
package udpProtocol;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
public class Client {
public static void main(String[] args) throws Exception{
//[1] 데이터그램 소켓으로 가야하는 곳을 지정
DatagramSocket datagramSocket = new DatagramSocket();
InetAddress ia = InetAddress.getByName("localhost");
for(int i = 1; i <= 3; i++) {
//[2] 데이터그램 패킷으로 데이터를 묶어둔다.
String data = "데이터"+i;
byte[] byteArr = data.getBytes("UTF-8");
DatagramPacket datagramPacket = new DatagramPacket(
byteArr, byteArr.length,ia,8000
);
//[3] 패킷을 소켓을 통해 전송한다.
datagramSocket.send(datagramPacket);
}//end for
//[4] 소켓을 닫는다.
datagramSocket.close();
}//end main
}
<Server>
package udpProtocol;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
public class Server {
public static void main(String[] args) throws Exception{
//[1] 소켓을 연다.
DatagramSocket datagramSocket = new DatagramSocket(8000);
//[2] 패킷 단위로 데이터를 받는다.
//쓰레드를 형성해서 무한 루프로 데이터를 받는다.
Thread thread = new Thread() {
@Override
public void run() {
System.out.println("수신 시작");
try {
while(true) {
DatagramPacket packet = new DatagramPacket(new byte[100],100);
datagramSocket.receive(packet);
String data = new String(packet.getData(),0,packet.getLength(),"UTF-8");
System.out.println("[받은 내용 : "+packet.getSocketAddress()+"]"+data);
}
} catch (IOException e) {
System.out.println("[수신 종료]");
}
}
};//end thread
thread.start();
Thread.sleep(10000);
datagramSocket.close();
}//end main
}
>> 수신 결과
수신 시작
[받은 내용 : /127.0.0.1:55273]데이터1
[받은 내용 : /127.0.0.1:55273]데이터2
[받은 내용 : /127.0.0.1:55273]데이터3
[수신 종료]
★ 삭제할 때, Last in First Out 방식을 취할 경우, 배열 복사가 발생하지 않는다. (성능 ↑)
[예제 연습1]
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
public class ArrayListEx2 {
public static void main(String[] args) {
final int LIMIT = 10;
String source = "0123456789abcdefghijABCDEFGHIJ!@#$%^&*()ZZZ";
int length = source.length();
List list = new ArrayList(length/LIMIT+10);
for(int i = 0; i < length; i+=LIMIT) {
if(i+LIMIT < length)
list.add(source.substring(i,i+LIMIT));
else
list.add(source.substring(i));
}
for(int i = 0; i < list.size(); i++) {
System.out.println(list.get(i));
}
}//end main
}//end class
package mymain;
import java.util.Arrays;
public class _10_Question_Mabanjin {
public static void main(String[] args) {
/*
[마방진 원리]
대각선으로 이동하라(plus -1 on row +1 on col)
만약 바둑판의 행과 열을 모두 벗어날 경우(row<0,col>Max) 자기자신의 아래로 가라
그렇지 않고 바둑판의 행을 벗어날경우(row<0) row의 가장 아래로 가라
그렇지 않고 열을 벗어날 경우(col>Max), col의 가장 왼쪽으로 가라
그렇지 않고 (대각선 이동은 가능하나) 그 자리에 다른 값이 있을 경우 자기 자신의 아래로 가라
해당 위치에 다음 숫자를 넣어라
*/
int[][] testArr = new int[5][5];
Mabanjin.makeStartPoint(testArr);
for(int i = 0; i < testArr.length; i++) {
System.out.println(Arrays.toString(testArr[i]));
}
System.out.println();
Mabanjin.mabanjin(testArr);
for(int i = 0; i < testArr.length; i++) {
System.out.println(Arrays.toString(testArr[i]));
}
}
}
class Mabanjin{
public static void makeStartPoint(int[][] arr) {
//배열 값 초기화, 시작 포인트 1로 잡기
for(int i = 0; i < arr.length; i++) {
Arrays.fill(arr[i], 0);
}
arr[0][arr[0].length/2] = 1;
}
public static int[][] mabanjin(int[][] arr) {
final int ROW_MAX = arr.length;
final int COL_MAX = arr[0].length;
//배열 안에 넣을 리터럴(1부터 ~ n)
int n = 1;
//이동 포인트
int r = 0;
int c = arr[0].length/2;
for(int i = 0; i < ROW_MAX*COL_MAX-1; i++) {
r -= 1;
c += 1;
if(r < 0 && c > COL_MAX-1) {
r = r + 2;
c = c - 1;
}else if(r < 0) {
r = r+ROW_MAX;
}else if(c > COL_MAX-1) {
c = COL_MAX-c;
}else if(arr[r][c] > 0) {
r = r + 2;
c = c - 1;
}
arr[r][c] = ++n;
}
return arr;
}
}
