UDP 방식으로 데이터를 전송하기(JAVA - DatagramSocket, DatagramPacket 활용)

안녕하세요

이번 시간에는 TCP 방식이 아닌 UDP 방식으로 데이터를 전송하는

예제를 올려봅니다.

UDP 방식은 비록 비연결지향, 비신뢰적, 데이터가 순서대로 도착한다는 보장을 못한다는

단점이 있지만 TCP 방식보다 빠르게 데이터를 전달할수 있는 장점이 있습니다.

실시간 동영상 서비스는 UDP 방식으로 구현이 되죠


자 어쨋든 예제 바로 올려봅니다.


아래에 있는 소스는 UDP 데이터를 보내는 Sender 파일입니다.

=========================================================

import java.net.*;

import javax.swing.JOptionPane;

import java.io.*;
/* 데이터를 보내는 측
 * UDP방식 : 비연결 지향, 비신뢰적, 데이터가 순서대로 도착한다는 보장을 못함
 * 하지만 TCP방식보다 빠르게 전달된다.
 * DatagramPacket, DatagramSocket을 사용
 * - DatagramSocket : 데이터 송수신과 관련된 클래스(우체부)
 * - DatagramPacket : 주고 받을 데이터와 관련된 클래스(소포) / 수신을 위한 생성자와 송신을 위한 생성자 두 가지를 제공
 * TCP의 경우 스트림을 이용해 데이터를 주고 받지만 UDP의 경우 데이터그램을 이용해 데이터를 송수신한다
 *
 * */
public class UDPSender {

public static void main(String[] args) throws Exception {

String ip=JOptionPane.showInputDialog("IP주소를 입력하세요");
if(ip==null||ip.trim().isEmpty()){
ip="localhost";
}
InetAddress inet=InetAddress.getByName(ip);

//키보드 입력
BufferedReader key=new BufferedReader(new InputStreamReader(System.in));
System.out.println("보낼 내용을 입력하세요");
DatagramSocket ds=new DatagramSocket();

String sendMsg="";
while((sendMsg=key.readLine())!=null){
if(sendMsg.equalsIgnoreCase("x")) break; //종료
//문자열을 byte 배열에 담자
byte[] data=sendMsg.getBytes();
DatagramPacket pack=new DatagramPacket(data,data.length,inet,3000);
// 데이터, 보낼 데이터 길이, 받을 사람의 ip, 포트번호
ds.send(pack);
System.out.println("보낼 내용을 입력하세요");
}//while-----------------

if(ds!=null) ds.close();
}

}

=========================================================

위에서 udp 데이터를 전송했으면 당연히 받는 receiver가 필요합니다


=========================================================

import java.net.*;
import javax.swing.JOptionPane;
import java.io.*;

public class UDPReceiver {

public static void main(String[] args) throws Exception{

//데이터를 받기 위해 byte배열을 생성한다.
//UDP의 실제 데이터는 512바이트로 제한하는 경우가 많다.
byte[] buffer=new byte[100];

DatagramSocket ds=new DatagramSocket(3000);
DatagramPacket pack=new DatagramPacket(buffer,buffer.length);

while(true){
ds.receive(pack);
byte[] bmsg=pack.getData();
String msg=new String(bmsg,0,pack.getLength());
System.out.println(pack.getAddress()+"로 부터 ["+pack.getPort()+"]번 포트에서 온 메시지: "+msg);
}
}
}

=========================================================


위의 소스를 실행하기 위해서는 도스창에서 실행시키는게 좋습니다.

화면은 아래와 같습니다

UDPSender를 실행시키면 ip주소를 입력하라는 메시지가 나옵니다

저는 그냥 'localhost' 라고 입력하겠습니다.

 

그리고 보낼 내용을 입력하라는 메시지가 나옵니다

저는 '안녕하세요', '반갑습니다' 라고 보내겠습니다

UDPReceiver를 보면 제가 보낸 메시지가 정상적으로 출력이 됩니다

어때요 참 쉽죠? ㅎ

Preparedstatement 인터페이스를 활용하여 자바 jdbc 효율적으로 컴파일해보자

안녕하세요

이번 시간에는 다시 자바 jdbc 진도를 나가려고 합니다.

아 자바도 좋지만,

요새 최순실 사태로 나라가 개판이네요...

정말 대한민국이 부끄럽습니다

빨리 박근혜가 하야하고 최순실도 구속하고 그 일가들 재산 모두 몰수 했으면 좋겠습니다


자 어쨋든 소스 코드와 결과 화면 보여드리겠습니다


==========================================================


public class PreparedStatementTest2 {

public static void main(String[] args) throws Exception {

//메모 테이블의 내용을 수정하자 (작성자, 메모내용, 작성일)
Scanner sc = new Scanner(System.in);
System.out.println("수정할 글번호 입력=>"); // PK = WHERE 조건절
int idx = sc.nextInt();
System.out.println("수정할 작성자 입력=>");
String name = sc.next();
sc.skip("\r\n"); // 엔터값 건너뛰기
System.out.println("수정할 메모내용 입력=>");
String msg = sc.nextLine();
System.out.println(idx+"/"+name+"/"+msg);

FileReader fr = new FileReader("DB.properties");
Properties p = new Properties();
p.load(fr);

// 드라이버 로드
Class.forName(p.getProperty("driver"));
String url = p.getProperty("dburl");
String user = p.getProperty("user");
String pwd = p.getProperty("pwd");

Connection con = DriverManager.getConnection(url,user,pwd);
System.out.println("DB연결 성공");

//PreparedStatement는 sql문을 전처리(미리 컴파일)
//시켜놓기 때문에 객체를 얻어오기 전에 미리 sql문을 작성해 놓아야 한다.
String sql = "UPDATE memo SET name=?, msg=?, wdate=sysdate WHERE idx=?";
/* ?
* IN Parameter(?를 말함)
* PreparedStatment는 ?를 제외한 sql문을 DB 포맷에 맞게
* 컴파일 하여 미리 준비시켜 놓는다
* */

PreparedStatement pstmt=con.prepareStatement(sql); // ? 를 제외하고 이 때 딱 한번 컴파일함
//Statement stmt = con.createStatement(sql);

//DB에 전송하기 전에 IN Parameter 값 셋팅
pstmt.setString(1, name); // 첫번째 ?
pstmt.setString(2, msg); // 두번째 ?
pstmt.setInt(3, idx); // 세번째 ?

int cnt=pstmt.executeUpdate(); // DB에 전송

String str=(cnt>0)?"성공":"실패";
System.out.println(str);

pstmt.close();
con.close();
sc.close();


}

}


==========================================================

결과 화면




현재 오라클 memo 테이블에 위와 같이 데이터가 있습니다

저는 4번째 튜플을 바꾸겠습니다.

위의 작성한 소스코드를 run 하면

수정할 글번호,작성자,메모내용을 입력하라고 합니다

저는 4번째 데이터를 바꾸기 위해

작성자를 '최순실' 로, 메모내용을 '나는 역적입니다' 로 바꾸겠습니다

다시 오라클에서 조회하게 되면

짜잔~

4번째 튜플이 바뀌었네요 ㅎㅎ

아무튼 퍼킹 코리아 정신좀 차렸으면 좋겠습니다

텍스트가 아닌 파일 형태로 클라이언트가 서버에게 파일 전송하기 - Java~!!

안녕하세요

오늘도 자바 포스팅을 써봅니다.

지금까지 에코 서버/클라이언트, 실시간 채팅 모두 다 텍스트로만 데이터를 전송했습니다

이번 시간에는 텍스트 뿐만 아니라 파일을 전송할 수 있는 예제를 올려봅니다.

자 그럼 잘 봐주세요~!!


서버.java

=========================================================


//3 - FTPServer 자체가 스레드되게 바로 스레드 상속
public class FTPServer extends Thread {

private ServerSocket server;
private Socket sock;
private String upDir="C:/MyJava/Upload";
private ObjectInputStream ois; // 파일명, 파일 등을 받을 수 있는 스트림
private FileOutputStream fos; // 파일로 내보내는 스트림 - (동영상, 이미지) 파일 형태는 1바이트 기반이 적합 / 문자 형태는 2바이트 기반

public FTPServer(){
try {
server=new ServerSocket(7788);
} catch (Exception e) {
e.printStackTrace();
}

}

public void run(){
out.println("FTPServer Started...");
try {
while(true){
sock=server.accept();
out.println(sock.getInetAddress()+"가 접속해옴");
ois=new ObjectInputStream(sock.getInputStream());
//서버가 파일명을 보내오는 것을 받자
String fileName=ois.readUTF(); // 문자열을 받기 위해 readUTF 사용
out.println(fileName);
String path=upDir+"/"+fileName; // 절대경로 지정
fos=new FileOutputStream(path); // 절대경로에 파일을 내보내어 생성한다.

//서버가 파일을 보내오는 것을 받자
int input=0, count=0; // count는 파일 크기 측정하기 위해
byte[] data=new byte[1024]; // 1kb씩. 빠르게 하려면 값을 더 크게 줘도 된다

//C:/MyJava/Upload 경로에 파일을 내보내기
while((input=ois.read(data))!=-1){
fos.write(data, 0, input);
fos.flush();
count+=input;
out.println(count+"byte 업로드중...");
}

if(fos!=null) fos.close();
if(ois!=null) ois.close();
if(sock!=null) sock.close();
}

} catch (Exception e) {
e.printStackTrace();
}

}

public static void main(String[] args) {

FTPServer fserver=new FTPServer();
fserver.start();
}
}


=========================================================


클라이언트.java



=========================================================


package net.day2;

import java.io.*;
import java.net.*;
import javax.swing.ImageIcon;
import javax.swing.JFileChooser;
import javax.swing.JLabel;
import javax.swing.JOptionPane;

//3
//192.168.10.3
public class FileUploadGUI extends javax.swing.JFrame {

Socket sock;
     ObjectOutputStream oos;
     FileInputStream fis;
     File file1;
     PrintWriter pw;

    public FileUploadGUI() {
        initComponents();
    }

    @SuppressWarnings("unchecked")
    // <editor-fold defaultstate="collapsed" desc="Generated Code">                        
    private void initComponents() {

        jPanel1 = new javax.swing.JPanel();
        tfHost = new javax.swing.JTextField();
        tfFile = new javax.swing.JTextField();
        btFile = new javax.swing.JButton();
        btUpload = new javax.swing.JButton();
        lb = new javax.swing.JLabel();

        setDefaultCloseOperation(javax.swing.WindowConstants.EXIT_ON_CLOSE);
        setTitle("FileUpload");

        jPanel1.setBorder(new javax.swing.border.MatteBorder(null));

        tfHost.setText("localhost");
        tfHost.setBorder(javax.swing.BorderFactory.createTitledBorder("업로드 할 서버 IP 주소"));

        tfFile.setBorder(javax.swing.BorderFactory.createTitledBorder("업로드 할 파일명"));

        btFile.setText("파일찾기");
        btFile.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btFileActionPerformed(evt);
            }
        });

        btUpload.setText("Upload");
        btUpload.addActionListener(new java.awt.event.ActionListener() {
            public void actionPerformed(java.awt.event.ActionEvent evt) {
                btUploadActionPerformed(evt);
            }
        });

        javax.swing.GroupLayout jPanel1Layout = new javax.swing.GroupLayout(jPanel1);
        jPanel1.setLayout(jPanel1Layout);
        jPanel1Layout.setHorizontalGroup(
            jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(jPanel1Layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.TRAILING, false)
                    .addComponent(tfFile)
                    .addComponent(tfHost, javax.swing.GroupLayout.DEFAULT_SIZE, 380, Short.MAX_VALUE))
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.UNRELATED)
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
                    .addComponent(btFile, javax.swing.GroupLayout.DEFAULT_SIZE, 92, Short.MAX_VALUE)
                    .addComponent(btUpload, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE))
                .addContainerGap())
        );
        jPanel1Layout.setVerticalGroup(
            jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(jPanel1Layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING, false)
                    .addComponent(tfHost, javax.swing.GroupLayout.DEFAULT_SIZE, 54, Short.MAX_VALUE)
                    .addComponent(btUpload, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE))
                .addPreferredGap(javax.swing.LayoutStyle.ComponentPlacement.UNRELATED)
                .addGroup(jPanel1Layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING, false)
                    .addComponent(btFile, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)
                    .addComponent(tfFile, javax.swing.GroupLayout.DEFAULT_SIZE, 55, Short.MAX_VALUE))
                .addContainerGap(25, Short.MAX_VALUE))
        );

        lb.setBorder(new javax.swing.border.SoftBevelBorder(javax.swing.border.BevelBorder.RAISED));

        javax.swing.GroupLayout layout = new javax.swing.GroupLayout(getContentPane());
        getContentPane().setLayout(layout);
        layout.setHorizontalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(javax.swing.GroupLayout.Alignment.TRAILING, layout.createSequentialGroup()
                .addContainerGap()
                .addGroup(layout.createParallelGroup(javax.swing.GroupLayout.Alignment.TRAILING)
                    .addComponent(lb, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE)
                    .addComponent(jPanel1, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, Short.MAX_VALUE))
                .addContainerGap())
        );
        layout.setVerticalGroup(
            layout.createParallelGroup(javax.swing.GroupLayout.Alignment.LEADING)
            .addGroup(layout.createSequentialGroup()
                .addContainerGap()
                .addComponent(jPanel1, javax.swing.GroupLayout.PREFERRED_SIZE, javax.swing.GroupLayout.DEFAULT_SIZE, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addGap(18, 18, 18)
                .addComponent(lb, javax.swing.GroupLayout.PREFERRED_SIZE, 331, javax.swing.GroupLayout.PREFERRED_SIZE)
                .addContainerGap(26, Short.MAX_VALUE))
        );

        pack();
    }// </editor-fold>                      

    JFileChooser fileDial=new JFileChooser("C:/MyJava/"); // 기준 경로 지정
    private void btFileActionPerformed(java.awt.event.ActionEvent evt) {                                      
       
    //파일 다이얼로그를 띄워 업로드할 파일을 선택한다
    fileDial.showOpenDialog(this);
    File selFile=fileDial.getSelectedFile();
    tfFile.setText(selFile.getAbsolutePath());
    String filename=selFile.getName();
    //파일이 이미지 파일이면 lb에 미리보기를 해주자
    filename=filename.toLowerCase(); // 파일 이름을 전부 소문자로 바꾸기
    if(filename.endsWith(".jpg")||filename.endsWith(".png")||filename.endsWith(".gif")){
    lb.setIcon(new ImageIcon(selFile.getAbsolutePath()));
    lb.setText("");
    lb.setHorizontalAlignment(JLabel.CENTER);
    }
    }                                    

    private void btUploadActionPerformed(java.awt.event.ActionEvent evt) {                                        
       
    // 파일을 서버에 전송하는 스레드 생성 및 동작
    SenderThread tr=new SenderThread();
    tr.start();
    }
   
    class SenderThread extends Thread{
   
    public void run(){
    // ftpserver에 접속하자(아이피, 포트번호)
    String serverip=tfHost.getText();
    int port=7788;
    if(serverip==null||serverip.trim().isEmpty()){
    JOptionPane.showMessageDialog(lb, "서버의 IP 주소를 입력하세요");
    tfHost.requestFocus();
    return;
    }//if------

    try{
    // 소켓 생성
    sock = new Socket(serverip, port);
    // 타이틀에 연결 결과 출력
    setTitle("##서버와 접속됨");
    //소켓 출력스트림=>ObjectOutputStream 필터링
    //클라이언트(OjbectInputStream)에게 파일을 보낸다
    oos = new ObjectOutputStream(sock.getOutputStream());
    //파일 입력스트림=>FileInputStream
    //File chooser에서 선택한 파일을 읽어들인다
    file1 = fileDial.getSelectedFile();
    fis = new FileInputStream(file1);
    //파일명을 서버에 전송한다.
    String fname = file1.getName();
    pw = new PrintWriter(sock.getOutputStream(),true);
    oos.writeUTF(fname);
    oos.flush();
    //파일을 읽으면서 소켓출력 스트림을 통해 파일 데이터를 내보낸다.
    int input=0, count=0;
    byte[] data = new byte[1024];
    while((input=fis.read(data))!=-1){
    oos.write(data, 0, input);
    oos.flush();
    count+=input;
    System.out.println(count+"바이트 전송중...");
    }
   
    if(pw!=null) pw.close();
    if(oos!=null) oos.close();
    if(fis!=null) fis.close();
    if(sock!=null) sock.close();
    JOptionPane.showMessageDialog(lb, "업로드 완료!");
    }catch(Exception e){
    System.out.println("예외: "+e);
    }
    }
    }

    public static void main(String args[]) {
        try {
            for (javax.swing.UIManager.LookAndFeelInfo info : javax.swing.UIManager.getInstalledLookAndFeels()) {
                if ("Nimbus".equals(info.getName())) {
                    javax.swing.UIManager.setLookAndFeel(info.getClassName());
                    break;
                }
            }
        } catch (ClassNotFoundException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (InstantiationException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (IllegalAccessException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        } catch (javax.swing.UnsupportedLookAndFeelException ex) {
            java.util.logging.Logger.getLogger(FileUploadGUI.class.getName()).log(java.util.logging.Level.SEVERE, null, ex);
        }
        //</editor-fold>

        /* Create and display the form */
        java.awt.EventQueue.invokeLater(new Runnable() {
            public void run() {
                new FileUploadGUI().setVisible(true);
            }
        });
    }

    // Variables declaration - do not modify                    
    private javax.swing.JButton btFile;
    private javax.swing.JButton btUpload;
    private javax.swing.JPanel jPanel1;
    private javax.swing.JLabel lb;
    private javax.swing.JTextField tfFile;
    private javax.swing.JTextField tfHost;
    // End of variables declaration                  
}

=========================================================


실행 결과 화면은 다음과 같습니다

서버를 실행하고 클라이언트를 실행하면 위와 같은 창이 나옵니다.

저는 제가 좋아하는 설현 움짤을 업로드 했습니다.

그리고 업로드 할 서버 IP 주소(자신의 IP) 주소를 적고

업로드 버튼을 누르면..

업로드가 완료됩니다.

이때 클라이언트, 서버 창에는 그동안 몇바이트를 업로드 했는지가 출력이 됩니다

위의 소스를 실행하기 위해서 반드시 'Upload' 라는 폴더가 있어야 합니다

그 폴더를 안만들고 백날 실행해봐야 되지 않습니다.

이 점 유의하시면서 이상 포스팅을 마칩니다

왓? 자바에서 서버 클라이언트 1대1 실시간 통신 예제가 있다고?

안녕하세요

이번 시간에는 이전 예제 에코 서버와 클라이언트의 정적인 채팅이 아닌

실시간 채팅 예제를 올려봅니다.

스레드 하나를 썼을 뿐인데 실시간이 지원되네요

어쨋든 소스 코드 올려봅니다.

렛츠고~!


=========================================================


public class ConsoleChatServer {

ServerSocket server;
Socket sock;
BufferedReader key, in;
PrintWriter pout;
final int port=7777;

public ConsoleChatServer(){
try {
out.println("ConsoleChatServer Started..");
server=new ServerSocket(port);
sock = server.accept();
out.println("##클라이언트와 연결됬음##["+sock.getInetAddress()+"]");
//1) 키보드 입력 스트림 생성
key=new BufferedReader(new InputStreamReader(System.in));
//2) 클라이언트의 메시지를 듣는 스트림
in=new BufferedReader(new InputStreamReader(sock.getInputStream()));
//3) 클라이언트에게 메시지를 보내는 스트림
pout=new PrintWriter(sock.getOutputStream(),true);
//4) 클라이언트의 메시지를 듣는 스레드 동작
ChatThread listener=new ChatThread();
listener.start();
//5) 키보드 입력을 통해 클라이언트에게 메시지를 보낸다
String mymsg="";
while((mymsg=key.readLine())!=null){
pout.println(mymsg);
}
} catch (Exception e) {
out.println("예외: "+e);
closeAll();
}
}// 생성자 ------------------------
//inner class
class ChatThread extends Thread{
// 클라이언트가 보내오는 메시지를 무한정 듣고 콘솔에 출력한다.
public void run(){
try{
while(true){
String cmsg=in.readLine();
out.println("From Client>>"+cmsg);

}//while------
}catch(IOException e){
out.println("예외:[클이 퇴장했어요] "+e);
closeAll();
}
}//run()------
} ///////////////////////
private void closeAll(){
try {
if(in!=null) in.close();
if(pout!=null) pout.close();
if(key!=null) key.close();
if(sock!=null) sock.close();
if(server!=null) server.close();
} catch (Exception e) {
out.println("closeAll()에서 예외 : "+e);
}
}
public static void main(String[] args) throws IOException {
new ConsoleChatServer();
}
}


=========================================================

위의 예제는 서버이고, 아래 예제는 클라이언트입니다.



=========================================================


public class ConsoleChatClient {

String ip="192.168.10.12";
final int port = 7777;
Socket sock;
//키보드입력, 서버로부터 듣는거
BufferedReader key, in;
PrintWriter pw;

//?
public ConsoleChatClient() throws IOException{
//소켓 객체 생성
sock = new Socket(ip, port);
out.println("##서버와 접속됨");

//필요한 스트림 생성 또는 할당
//키보드 입력
key = new BufferedReader(new InputStreamReader(System.in));

InputStream is=sock.getInputStream();
in = new BufferedReader(new InputStreamReader(is));

// PrintWriter 자체가 브리지 스트림을 안거친다. 그래서 BufferedWriter를 안쓴다
pw = new PrintWriter(sock.getOutputStream(),true);

//서버의 메시지를 듣는 스레드 생성 및 동작
ChatThread listener=new ChatThread();
listener.start();

//키보드 입력해서 서버에 메시지 전송
String mymsg="";
while((mymsg=key.readLine())!=null){
pw.println(mymsg);
}
}
class ChatThread extends Thread{
public void run(){
try {
while(true){
String smsg=in.readLine();
out.println("From Server>>"+smsg);
}
} catch (IOException e) {
out.println("예외:[서버가 퇴장했어요] "+e);
closeAll();
}
}
}
private void closeAll(){
try{
//순서? DB는 반드시 순서를 지켜야한다
if(in!=null) in.close();
if(key!=null) key.close();
if(pw!=null) pw.close();
if(sock!=null) sock.close();
}catch(IOException e){
out.println("closeAll()에서 예외 : "+e);
}
}

public static void main(String[] args) throws IOException { // 최종적으로 IOException은 JVM이 처리
new ConsoleChatClient();
}
}

=========================================================


사실 이번 예제는 이전 에코서버 예제와 그렇게 큰 차이는 없으나

스레드의 유무로 훨씬 더 개선된 퍼포먼스를 내는 채팅이 구현되었습니다.

자 그럼 실행화면 보실까요~!

위와 같이 서버를 실행하고 이후 클라이언트를 실행하면

서버에 접속되었다는 멘트가 출력이 됩니다

그리고 서버에게 '안녕하세요 클라이언트입니다' 라고 메시지를 보내게 되면

서버에서 클라이언트가 보낸 메시지가 출력이 되고

서버도 클라이언트에게 메시지를 보내면..

클라이언트도 서버가 보낸 메시지를 출력하게 됩니다

다음 예제에서도 알찬 예제로 찾아뵙겠습니답~!!

에코(Echo) 서버와 클라이언트를 구현해보장~!!

안녕하세요

이번 시간에는 자바에서 에코 서버와 클라이언트를 구현해보는 시간을 가지겠습니다

에코 서버는 클라이언트가 보내주는 데이터에 대해 바로 답장해주는 서버로

실시간 채팅과는 좀 더 폐쇄적이고 수동적인 채팅 스타일 방식을 가졌다고 보면 됩니다.

자 어쨋든 예제 바로 들어갑니다


=========================================================

* [구현할 내용
 * Client가 Server에 접속하면
 * [1] 서버는 먼저 클라이언트에게 "안녕하세요? 클라이언트(ip)님~~" 메시지를 보낸다
 * [2] 클라이언트는 키보드 입력을 통해 서버에 응답 메시지를 보낸다.
 * [3] 서버는 클라이언트이 메시지를 듣고 메시지를 분석해서 3가지 유형의 답변을 보낸다.
 * (1) "안녕하세요" 또는 "하이" 란 메시지가 오면 => "반가워요~~"
 *  (2) "오늘 날짜는" 이란 메시지가 오면 => 오늘 날짜를 알려준다
 *  (3) 그 외 다른 메시지가 오면 => '~~님 어여 가!!" 란 메시지를 보내자
 *
 * */

// 순차적인 채팅. 메아리 채팅임

public class EchoServer {

public static void main(String[] args) throws IOException {

//ServerSocket, Socket
ServerSocket server=new ServerSocket(6666);
out.println("EchoServer Ready...");
Socket sock=server.accept();
String cip=sock.getInetAddress().getHostAddress(); // 클라이언트 IP 주소
out.println(cip+"님이 접속했어요");

//클라이언트가 접속하면 먼저 인사말을 건낸다
OutputStream os=sock.getOutputStream();
PrintWriter pout=new PrintWriter(os,true); // true값을 주면 auto flush
pout.println("안녕하세요? "+cip+"님~~");

// 클라이언트의 메시지를 듣는 스트림 얻기=> 필터링
InputStream is = sock.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));

// 반복문 돌면서 클라이언트이 메시지를 계속 듣고 그 메시지를 분석하여
// 메아리를 보낸다
//indexof 없으면 if(-1)

String cmsg="";
while((cmsg=br.readLine())!=null){
//cmsg를 분석하자
int i=cmsg.indexOf("안녕");
int j=cmsg.indexOf("하이");
int k=cmsg.indexOf("날짜");

if(i!=-1||j!=-1){
pout.println("반갑습니다");
}else if(k!=-1){
pout.println(new Date().toString());
}else{
pout.println(cip+"님 어여 가~~~");
}
}

br.close();
pout.close();
is.close();
os.close();
sock.close();
server.close();

}
}


=========================================================

현재 위의 소스는 에코서버쪽의 소스입니다.

자 다음은 에코 클라이언트의 소스입니다

=========================================================


public class EchoClient {

public static void main(String[] args) throws IOException {
//Socket생성=> 서버의 ip주소, port번호 필요
String ip=JOptionPane.showInputDialog("서버의 아이피 주소를 입력하세요");
int port=6666;

Socket sock=new Socket("ip주소",6666);
out.println("##서버와 접속됨");

//2) 서버에 접속하면 서버가 먼저 인사말을 건낸다.
//=> 클라이언트는 인사말을 듣고 콘솔에 출력하자
InputStream is=sock.getInputStream();
BufferedReader br=new BufferedReader(new InputStreamReader(is));
String serverMsg=br.readLine();
out.println("From Server>>"+serverMsg);

//3) 서버에 메시지를 보내기 위해 키보드 입력 스트림과 서버에 출력하는 스트림이 필요
//키보드 입력 스트림(System.in)
BufferedReader key=new BufferedReader(new InputStreamReader(System.in));

//4) 서버에 메시지를 보낼 출력스트림
PrintWriter pw=new PrintWriter(sock.getOutputStream(),true); // auto flush

String clientMsg="";

while((clientMsg=key.readLine())!=null){ // 키보드 입력
pw.println(clientMsg); // 5) 서버에 메시지를 전송
//6) 서버에서 보내오는 메시지를 듣는다
out.println("서버로부터 보낼 메시지를 입력하세요");
serverMsg=br.readLine();
out.println("From Server>>"+serverMsg);
}
}
}

=========================================================


자 이로써 두 개의 에코서버, 에코클라이언트 소스를 작성해봤습니다.

이 두 개의 소스코드의 실행결과는 아래와 같습니다(참고로 서버부터 먼저 실행해야합니다)

서버를 실행하면, 클라이언트의 접속을 무한정 기다립니다.

그리고 클라이언트를 실행하면 JOption 창이 뜨면서 서버의 아이피 주소를 입력하라고

나오게 됩니다.

접속이 되면 서버로부터 '안녕하세요' 라는 글귀가 나오고

서버에게 '날짜' 라는 키워드를 입력하면 서버가 날짜를 보내오고

안녕, 하이 라는 키워드를 입력하면 '반갑습니다' 라는 키워드를 보냅니다

서버와 클라이언트가 통신하는 자바 예제!!

안녕하세요 이번 시간에는

채팅 프로그램의 시발점인 기초 예제를 하나 올려봅니다.

서버와 클라이언트가 간단하게 통신하는 프로그램으로

내일도 이와 관련된 예제를 올리겠습니다.


저도 오늘 기초만 배우는 거라 쉽지가 않네요

소스 파일은 두개로

서버와 클라이언트 두개의 파일로 있습니다.


먼저 서버 파일 부터 올립니다

TCPServer.java ===============================================

/* 서버단
 * - ServerSocket과 Socket이 필요
 * - 클라이언트가 접속해오면 "행운의 숫자" 를 보내보자
 * */

public class TCPServer {

public static void main(String[] args) throws IOException {

//1. 서버 소켓을 생성한다 => 열어놓을 포트번호 필요(특정한 포트 외에는 아무렇게 지정 가능)
ServerSocket server = new ServerSocket(5555);

//2. 서버소켓이 클라이언트의 연결을 기다림
System.out.println("클라이언트 연결을 기다림..");
while(true){
Socket sock=server.accept();
/* 클라이언트가 접속해오기를 기다리고 있다가 클라이언트가 접속해오면
* 클라이언트와 연결된 소켓 객체를 반환한다.
* */
System.out.println("클라이언트가 접속했어요!!");
InetAddress inet=sock.getInetAddress();
System.out.println("클라이언트의 IP: "+inet.getHostAddress());

int num = new Random().nextInt(100)+0; // 0부터 99까지 랜덤하게 발생

//서버가 클라이언트에게 숫자 데이터를 보낸다.
//출력스트림 활용
OutputStream os = sock.getOutputStream();

//자바의 다양한 데이터(자료형)를 보내는 DataOutputStream 활용
DataOutputStream dos = new DataOutputStream(os);
dos.writeInt(num);
dos.flush();

//클라이언트가 보내는 메시지를 듣고 콘솔에 출력하자
InputStream is = sock.getInputStream();
DataInputStream dis = new DataInputStream(is);
System.out.println("From Client>>>"+dis.readUTF());

//원래는 null 체크하고 종료하면 좋음
dos.close(); dis.close();
os.close(); is.close();
if(sock!=null) sock.close();
}

========================================================


그 다음은 클라이언트 파일입니다.


TCPClient.java===============================================

/* 서버단
 * - ServerSocket과 Socket이 필요
 * - 클라이언트가 접속해오면 "행운의 숫자" 를 보내보자
 *
 * */

public class TCPClient {

public static void main(String[] args) throws IOException{

Socket sock=new Socket("자신의 ip 주소",5555);
//클라이언트 소켓에서는 서버의 IP주소와 port번호가 필요하다. (집에서 할 때는 cmd->ipconfig->ipv4 주소로 변경하자)
//서버와 연결되면 Socket이 생성되고, 연결이 안되면 예외가 발생됨

System.out.println("서버와 연결됨");

//서버가 보낸 데이터를 듣기 위해 스트림 연결
InputStream is=sock.getInputStream();
DataInputStream dis=new DataInputStream(is);
int num=dis.readInt();
JOptionPane.showMessageDialog(null, "서버가 보내온 행운의 숫자:"+num);

// 서버에게 클라이언트가 메시지를 보내자
java.util.Scanner sc = new java.util.Scanner(System.in);
System.out.println("메시지를 입력하세요=>");
String str=sc.nextLine();
// 출력 스트림 얻기 => sock 통해서
OutputStream os = sock.getOutputStream();
//필터링
DataOutputStream dos=new DataOutputStream(os);
dos.writeUTF(str);
dos.flush();

dos.close();
dis.close();
is.close();
os.close();
sock.close();
}
}

========================================================


자 이번 예제는 먼저 서버부터 실행하고 바로 클라이언트를 실행해야 합니다

이번 예제는 특별히 자바 콘솔창이 아닌 도스창에서 실행하십쇼~!

 

먼저 서버를 실행하고 클라이언트를 실행하게 되면

클라이언트 창에서 서버가 보내온 행운의 숫자가 출력됩니다.

그 다음 클라이언트에서 서버에게 '안녕 서버야' 라는 메시지를 전송하게 되면..

서버에서는 안녕 서버야 라는 메시지가 출력이 되고

프로그램이 종료됩니다.

일단 서버와 클라이언트가 1대1 통신하는 간단한 예제를 끝으로 오늘 자바 네트워크 포스팅은 끝마치고 다른 포스팅을 올리겠습니다.

내일 다른 네트워크 예제로 뵙겠습니다~!

인터넷의 이미지를 자바 URL 클래스를 활용하여 얻어와 파일로 저장하기

안녕하세요

이번 시간에는 네이버나 구글, 기타 웹 페이지의 이미지를

URL 클래스를 이용해 담아와

파일로 저장하는 예제를 올려봅니다.


제가 불러들일 이미지는

박근혜 대통령이 이번에 최순실 사태로 국민들에게 고개 숙여 사죄하는 이미지입니다.

여담이지만 대한민국.. 제발 정신좀 차렸으면 좋겠습니다.

정말 안썩은 곳 찾기 힘들 정도로 우리나라 너무 부패합니다.

자 어쨋든 소스코드는 아래와 같습니다.

==========================================================


public class test {
public static void main(String[] args) throws IOException {

String str = "http://imgnews.naver.net/image/020/2016/10/26/81004225.1_99_20161026030722.jpg?type=w540";
URL url=new URL(str);
URLConnection ucon=url.openConnection();
ucon.connect(); // 연결

int fsize=ucon.getContentLength();
System.out.println("파일의 크기 : "+fsize);
String contentType=ucon.getContentType();
System.out.println("파일의 컨텐트 타입 : "+contentType);

InputStream is=ucon.getInputStream(); // 입력스트림을 얻자
//인터넷 상의 이미지 파일을 로컬 컴퓨터로 카피하세요
//에러코드 - 2바이트 스트림(InputStreamReader)을 쓰면 안됨
//InputStreamReader ir = new InputStreamReader(is);
//copy3.jpg

//조금 비효율적
/* File file1 = new File("copy3.jpg");
FileOutputStream fos = new FileOutputStream(file1);*/

//효율적
BufferedInputStream bis=new BufferedInputStream(is);
BufferedOutputStream bos=new BufferedOutputStream(new FileOutputStream("copy3.jpg"));

//count 변수는 파일 크기를 알아보기 위해서임
int input=0, count=0;

byte[] data=new byte[1024];

while((input=bis.read())!=-1){
bos.write(data, 0, input);
bos.flush();
count+=input;
}

bos.close();
bis.close();
is.close();
System.out.println(count+"바이트 카피 완료!");

}
}

==========================================================

실행 결과

콘솔창에는 위와 같이 파일의 크기, 컨텐트 타입 등의 정보가 출력되고

패키지 익스플로러를 새로 고침하면

copy3.jpg 라는 파일이 생성됩니다.

네..

이상으로 포스팅 마치겠습니다~!

네이버 기사의 html 코드를 자바 콘솔창에 보여주고 HTML 파일로 저장시키기

안녕하세요

이번 시간에는 자바의 URI 클래스를 이용하여

네이버 기사를 복사하여 자바 콘솔창에 보여주고,

HTML 파일로 저장 시켜 볼 수 있는 예제를 올려봅니다.


==========================================================


import java.io.IOException;
import java.net.*;
import java.io.*;

public class test {
public static void main(String[] args) {
//wetrNewsDetail.nhn의 nhn은 노출을 피하기 위해 논리적으로 보여주는 이름이고 실제로는 jsp 같은 파일로 구성되어 있음
String urlStr="http://weather.naver.com/news/wetrNewsDetail.nhn?pressId=056&newsId=0010377477";
try{
URL url=new URL(urlStr);
// 위의 url 주소의 프로토콜, 호스트, 포트번호, 경로, 쿼리스트링, 레퍼런스를 알아보자
System.out.println("프로토콜: "+url.getProtocol());
System.out.println("호 스 트: "+url.getHost());
System.out.println("포트번호: "+url.getDefaultPort());
System.out.println("Path  : "+url.getPath());
System.out.println("QueryString: "+url.getQuery());
System.out.println("Reference: "+url.getRef());

//위 리소스 파일을 읽어서 copy.html로 저장하고 콘솔에도 출력하자.
//소켓 연결 안해도 가능
InputStream is=url.openStream();
//BufferedReader로 필터링해서 줄단위로 읽고 출력
BufferedReader br=new BufferedReader(new InputStreamReader(is,"UTF-8"));
//콘솔 출력용
PrintWriter pw=new PrintWriter(System.out, true);
//FileWriter fw=new FileWriter("copy.html"); // 파일로 내보낼때 한글 깨짐
OutputStreamWriter fw=new OutputStreamWriter(new FileOutputStream("copy.html"));
String line="";
while((line=br.readLine())!=null){
pw.println(line);
fw.write(line+"\r\n");
fw.flush();
}
br.close();
is.close();
pw.close();
fw.close();
}catch(MalformedURLException e){
e.printStackTrace();
}catch(IOException e){
e.printStackTrace();
}
}
}

==========================================================

위 소스 코드를 실행하면 두 가지 결과가 나옵니다.

첫번째는 자바 콘솔창에 위의 url 소스의 html 코드가 출력이 됩니다.

그리고 두 번째는 copy.html 이라는 파일이 생성되고 여기에도 html 코드가 있습니다.

아무튼 알아두면 유용한 예제입니다.