'소켓'에 해당되는 글 5건

php로 웹상의 파일 읽기(원격 리소스 읽기)

<?php
if (ini_get('allow_url_fopen') == '1') {
   // fopen() 이나 file_get_contents() 사용
} else {
   // curl 이나 함수 직접 작성
}

<?php
// 원격 파일을 사용하기 전에 성공적으로 open 되었는지 확인
if ($fp = fopen('http://www.google.com/', 'r')) {
   $content = '';
   // 전부 읽을때까지 계속 읽음
   while ($line = fread($fp, 1024)) {
      $content .= $line;
   }

   // content 사용
   // ...
} else {
   // 파일 open시 에러 발생
}

<?php
// 원격 파일을 사용하기 전에 성공적으로 open 되었는지 확인
if ($fp = fopen('http://www.google.com/', 'r')) {
   $content = '';
   // 전부 읽을때까지 계속 읽음
   while ($line = fgets($fp, 1024)) {
      $content .= $line;
   }

   // content 사용
   // ...
} else {
   // 파일 open시 에러 발생
}

<?php
$content = file_get_contents('http://www.google.com/');
if ($content !== false) {
   // content 사용
} else {
   // error 발생
}

<?php
// curl이 설치 되었는지 확인
if (function_exists('curl_init')) {
   // curl 리소스를 초기화
   $ch = curl_init(); 

   // url을 설정
   curl_setopt($ch, CURLOPT_URL, 'http://www.google.com'); 

   // 헤더는 제외하고 content 만 받음
   curl_setopt($ch, CURLOPT_HEADER, 0); 

   // 응답 값을 브라우저에 표시하지 말고 값을 리턴
   curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1); 

   // 브라우저처럼 보이기 위해 user agent 사용
   curl_setopt($ch, CURLOPT_USERAGENT, 'Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:1.7.5) Gecko/20041107 Firefox/1.0'); 

   $content = curl_exec($ch); 

   // 리소스 해제를 위해 세션 연결 닫음
   curl_close($ch);
} else {
   // curl 라이브러리가 설치 되지 않음. 다른 방법 알아볼 것
}

<?php
function getRemoteFile($url)
{
   // 1. host name과 url path 값을 획득

   // 2. 원격 서버에 접속

   // 3. 파일을 얻기위해 필요한 헤더들을 전송

   // 4. 원격 서버로부터 응답 받음

   // 5. header 부분 걷어냄

   // 6. 파일 content 리턴
}

<?php
Array
(
    [scheme] => http
    [host] => www.php-mysql-tutorial.com
    [path] => /somepage.php
)

<?php
Array
(
    [scheme] => http
    [host] => www.php-mysql-tutorial.com
    [user] => myusername
    [pass] => mypassword
    [path] => /somepage.php
    [query] => q=whatsthis
    [fragment] => ouch
)

<?php
function getRemoteFile($url)
{
   // host name 과 url path 값을 획득
   $parsedUrl = parse_url($url);
   $host = $parsedUrl['host'];
   if (isset($parsedUrl['path'])) {
      $path = $parsedUrl['path'];
   } else {
      // url이 http://www.mysite.com 같은 형식이라면
      $path = '/';
   }

   if (isset($parsedUrl['query'])) {
      $path .= '?' . $parsedUrl['query'];
   } 

   if (isset($parsedUrl['port'])) {
      $port = $parsedUrl['port'];
   } else {
      // 대부분의 사이트들은 80포트를 사용
      $port = '80';
   }

   $timeout = 10;
   $response = '';
   // 원격 서버에 접속한다
   $fp = @fsockopen($host, $port, $errno, $errstr, $timeout );

   if( !$fp ) {
      echo "Cannot retrieve $url";
   } else {
      // 필요한 헤더들 전송
      fputs($fp, "GET $path HTTP/1.0\r\n" .
                 "Host: $host\r\n" .
                 "User-Agent: Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:1.8.0.3) Gecko/20060426 Firefox/1.5.0.3\r\n" .
                 "Accept: */*\r\n" .
                 "Accept-Language: en-us,en;q=0.5\r\n" .
                 "Accept-Charset: ISO-8859-1,utf-8;q=0.7,*;q=0.7\r\n" .
                 "Keep-Alive: 300\r\n" .
                 "Connection: keep-alive\r\n" .
                 "Referer: http://$host\r\n\r\n");

      // 원격 서버로부터 response 받음
      while ( $line = fread( $fp, 4096 ) ) {
         $response .= $line;
      }

      fclose( $fp );

      // header 부분 걷어냄
      $pos      = strpos($response, "\r\n\r\n");
      $response = substr($response, $pos + 4);
   }

   // 파일의 content 리턴
   return $response;
}

<?php
fputs($fp, "GET $path HTTP/1.0\r\n" . "Host: $host\r\n\r\n");

간단한 소켓 클라이언트(Socket Client) 만들기 예제입니다.

JAVA를 이용한 간단한 소켓 클라이언트 (Socket Client) 만들기 예제입니다.

// 서버와 통신할 소켓 생성
Socket s = new Socket("localhost",3000);

// 소켓으로부터 inputStream 과 outputStream 얻기
OutputStream os = s.getOutputStream();
InputStream is = s.getInputStream();
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
BufferedReader br = new BufferedReader(new InputStreamReader(is));

// 서버에 메세지 전송하기
bw.write(" => 클라이언트 입니다. \n");

// 서버에서 메세지 받아오기
String message = br.readLine();

*** 소스

package com.redjava.interfaces.socket;

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

public class EchoClient{
 public EchoClient(){
  try{
   Socket s = new Socket("localhost",3000);
   
   OutputStream os = s.getOutputStream();
   InputStream is = s.getInputStream();
   BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
   BufferedReader br = new BufferedReader(new InputStreamReader(is));
   
   bw.write(" => 클라이언트 입니다. \n");
   bw.flush();
   
   String message = br.readLine();
   System.out.println("[서버 메세지] " + message);
  }catch(UnknownHostException e){
   System.out.println("[경고] 서버를 찾을 수 없습니다.");
  }catch(IOException e){
   System.out.println("[경고] 사용되지 않는 PORT 번호 입니다.");
  }
 }
 
 public static void main(String[] args){
  new EchoClient();
 }
}

간단한 소켓서버(Socket Sever) 만들기 예제입니다.

JAVA 로 구현하는 간단한 소켓서버 (Socket Server) 의 구현 예제 입니다.

*** 소스

package com.redjava.interfaces.socket;

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

public class EchoServer{
 public EchoServer(){
  try{
   ServerSocket ss = new ServerSocket(3000);
   System.out.println("=== 서버 가동 ===");
   
   Socket s = ss.accept();
   System.out.println("= 클라이언트 연결 소켓 생성 =");
   
   InetAddress userInfo = s.getInetAddress();
   String ip = userInfo.getHostAddress();
   System.out.println("[" + ip + "] 님 접속");
   
   InputStream is = s.getInputStream();
   OutputStream os = s.getOutputStream();
   BufferedReader br = new BufferedReader(new InputStreamReader(is));
   BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(os));
   
   String message = br.readLine();
   System.out.println("[메세지]" + message);
   
   bw.write("["+ip+"]님 환영합니다. \n");
   bw.flush();
  }catch(IOException e){
   System.out.println("[경고] 해당 PORT는 사용중입니다.");
  }
 }
 
 public static void main(String[] args){
  new EchoServer();
 }
}

소켓을 통해 네트워크 정보를 보는 기본적인 예제입니다.

네트워크 소켓을 열어서 간단한 정보를 확인하는 예제입니다.

----------network.java-------------

package com.redjava.java.network;

import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;

public class NetEcho {
 
   public static void main(String[] args) throws IOException {
   
     try {
      Socket echoSocket = new Socket("localhost", 80);
      System.out.println(echoSocket);
     }
     catch(UnknownHostException e) {
      System.err.println("Don't know about host: roseindi.");
      System.exit(1);
     }
     catch (IOException e) {
      System.err.println("I understand about "+ "the host: roseindi.");
      System.exit(1);
     }
   }

}

실행결과

Socket[addr=localhost/127.0.0.1,port=80,localport=51962]

getKeepAlive : 소켓이 살아있는지 죽었는지 확인하는 메소드

Server는 socket의 끊어지 상태 확인이 어려운 경우가 많으며
socket보다 방화벽의 connection timeout이 짧은 경우 종종 발생합니다.

서버는 소켓이 끊어진지 여부를 모르기 때문에 아래의 절차를 거쳐 socket close후 처리를 합니다.

if( socket.isConnected() == true && socket.getKeepAlive() == false) {
  socket.setKeepAlive(true);
  if(socket.getKeepAlive() == false) { // Socket 연결이 끊어 졌는지 확인
    socket.close();
    releaseSocket(socket, endpoint);
    socketsPool.clear(socketKey);
    socket = (Socket) socketsPool.borrowObject(socketKey);
  }
}

----- network.java ----
package com.redjava.java.network;

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

public class NetGetKeepAlive{
 
 public static final short TIME_PORT = 135;
 
 public static void main(String[] args) throws IOException{
  
  String hostName = null;
  System.out.println();
  
  try{
   Socket socket= new Socket(hostName,TIME_PORT);
   System.out.println("socket =" + socket);
   System.out.println("Keep Alive="+ socket.getKeepAlive());
   System.out.println("Send Buffer size ="+ socket.getSendBufferSize());
   System.out.println("output ="+socket.isOutputShutdown());
   System.out.println("port is =" + socket.getPort());
   System.out.println("socket address ="+socket.getLocalSocketAddress());
   InetAddress in= socket.getInetAddress();
   System.out.println(in);
   System.out.println("\n");
   System.out.print("RAW IP Address - (byte[]) : ");
   byte[] b1 = in.getAddress();
   
   for (int i=0; i< b1.length; i++) {
    if (i > 0) {
     System.out.print(".");}
     System.out.print(b1[i]);
   }

  }
  catch (UnknownHostException  e) {
   e.printStackTrace();
  }
  catch (IOException e) {
   e.printStackTrace();
  }
 }
}

--- 실행결과 ---
socket =Socket[addr=localhost/127.0.0.1,port=135,localport=52195]
Keep Alive=false
Send Buffer size =8192
output =false
port is =135
socket address =/127.0.0.1:52195
localhost/127.0.0.1

RAW IP Address - (byte[]) : 127.0.0.1