살아 숨 쉬는 웹 - 블루비

                
<rdf>
     <channel>
          .....
          .....
     </channel>

     <item>
          <title>My Title</title>
          <link>My URL</link>
          <description>My Description</description>
          .....
          .....
     </item>
</rdf>
		

                
<rss>
     <channel>
          .....
          .....

          <item>
               <title>My Title</title>
               <link>My URL</link>
               <description>My Description</description>
               .....
               .....
          </item>
     </channel>
</rss>		
		

                
function get_rss_feeds(& $rss_provider_name, & $rss_provider_url,
   & $max_rss_items_required) {	
   // max_rss_items_required가 0인지 확인
   if ($max_rss_items_required <= 0) {
      // 비어있는 배열 반환
      $empty_array = array();
      return($empty_array); 			
   } // End of if ($max_rss_items_required <= 0)
	
   // 계속 진행해 RSS 제공자로부터 RSS 내용을 가져온다.
   $received_rss_feeds = perform_curl_operation($rss_provider_url);
	
   // 비어있는가?
   if (empty($received_rss_feeds)) {
      // 비어있는 배열 반환
      $empty_array = array();
      return($empty_array); 	
   } // End of if (empty($received_rss_feeds))
	
   // RSS 피드 제공자로부터 비어있지 않은 결과를 받았다.
   // 받은 rss 피드 항목에서 값을 저장할 비어있는 배열 셋을 생성한다.
   $rss_feed_title_array = array();
   $rss_feed_url_array = array();
   $rss_feed_description_array = array();

   // 이제 개별 RSS 피드 항목을 파싱한다.
   $parser_result = parse_rss_feed_xml($received_rss_feeds, $max_rss_items_required,
      $rss_feed_title_array, $rss_feed_url_array, $rss_feed_description_array);
	
   // RSS 피드 XML 내용을 파싱할 수 있는지 점검한다.
   if ($parser_result == true) {
      // 성공적으로 RSS 피드 결과를 파싱했다.
      // 배열을 생성해 함수 설명 주석에 기술한
      // 결과로 배열을 채워넣는다.
      $result_array = array();
      // rss 제공자 이름을 채운다.
      $result_array[0] = $rss_provider_name;
      // 반환될 rss 피드 항목 개수를 채운다.
      $result_array[1] = sizeof($rss_feed_title_array);
      // RSS 피드 제목을 포함할 배열을 채운다.
      $result_array[2] = $rss_feed_title_array;
      // RSS 피드 URL을 포함할 배열을 채운다.
      $result_array[3] = $rss_feed_url_array;
      // RSS 피드 설명을 포함할 배열을 채운다.
      $result_array[4] = $rss_feed_description_array;
      // 이제 결과 배열을 반환한다.
      return($result_array);		
   } else {
      // RSS 피드 항목을 파싱하는 데 실패했다.
      // 결과로 비어있는 배열을 반환한다.
      $empty_array = array();
      return($empty_array); 			
   } // End of if ($parser_result == true)
} // End of function get_rss_feeds
		

                
function perform_curl_operation(& $remote_url) {
   $remote_contents = "";
   $empty_contents = "";

   // cURL 세션을 초기화하고 핸들을 얻는다.
   $curl_handle = curl_init();

   // cURL 세션이 열렸나?
   if ($curl_handle) {
      // 필요한 cURL 옵션을 설정한다.
      // URL 옵션 설정
      curl_setopt($curl_handle, CURLOPT_URL, $remote_url);
      // HEADER 옵션 설정. 출력에 HTTP 헤더 결과를 원하지 않는다.
      curl_setopt($curl_handle, CURLOPT_HEADER, false);
      // FOLLOWLOCATION 옵션 설정. 위치 헤더가 존재하면 따라간다.
      curl_setopt($curl_handle, CURLOPT_FOLLOWLOCATION, true);
      // WRITEFUNCTION 콜백을 사용하는 대신, curl_exec 함수를 위한 반환 값으로
      // 원격지 내용을 받는다.
      curl_setopt($curl_handle, CURLOPT_RETURNTRANSFER, true);

      // 원격지 URL 내용을 가져오려고 시도한다.
      // 이 함수는 내용을 전달 받을 때까지 멈춰있다.
      $remote_contents = curl_exec($curl_handle);
      // cURL을 정리한다.
      curl_close($curl_handle);
      
      // cURL 결과를 점검한다.
      if ($remote_contents != false) {
         return($remote_contents);
      } else {
         return($empty_contents);
      } // End of if ($remote_contents != false)  	
   } else {
      // cURL 초기화 실패
      // cURL 없이 할 수 있는 일은 없다.
      return($empty_contents);
   } // End of if ($curl_handle)
} // End of function perform_curl_operation
		

                
function parse_rss_feed_xml(& $received_rss_feeds, 
   & $max_rss_items_required, & $rss_feed_title_array, 
   & $rss_feed_url_array, & $rss_feed_description_array) {
   /*
    * PHP SimpleXML API를 사용해 XML 형식으로 인코딩된 RSS 피드를 파싱한다.

   RSS에는 0.91, 0.92, 1.0, 2.0이라는 다양한 버전이 존재한다.
   각 버전 사이에 존재하는 차이점은 다음에 소개하는 두 가지 형식에 나타나 있다.
    
   1) <rss><channel><item>...</item><item>...</item><item>...</item></channel></rss>
   2) <rdf><channel>...</channel><item>...</item><item>...</item><item>...</item></rdf>
    
   1번 형식에서, <item> 요소는 <channel> 요소의 자식이다.
   2번 형식에서, <item> 요소는 루트 요소인 <rss>나 <rdf>의 직계 자식이다.
   다시 말해, 2번 형식에서 <item> 요소는 <channel> 요소의 형제다.
   RSS 버전 1.0은 2번 형식을 사용하는 반면 나머지 버전은 1번 형식을 사용한다.
   양쪽 형식에서, <item>...</item> 사이의 자손에만 관심을 기울인다.
   여기서 사용하는 파싱 논리는 양쪽 형식을 모두 다뤄야 한다.
   */	
   // SimpleXML 객체 표현을 얻기 위해 XML 문자열을 올리는 작업부터 시작하자.
   $xml = simplexml_load_string($received_rss_feeds);

   // 유효한 XML 문서인가?
   if ((is_object($xml) == false) || (sizeof($xml) <= 0)) {	
      // XML 파싱 오류. 지금 바로 끝낸다.
      return(false);
   } // End of if ((is_object($xml) == false) ...
	
   // 이제 <item> 요소가 <channel> 요소의 자식인지 결정해야 한다.
   // 이럴 경우 위에서 설명한 형식 1이다. <item> 요소가 <rss>나 <rdf>
   // 루트 요소의 직계 자식이면 위에서 설명한 형식 2이다.
   $obj1 = $xml->item;
	
   if ((is_object($obj1) == false) || (sizeof($obj1) <= 0)) {
      // <item> 요소는 문서 root 요소의 직계 자식이 아니다.
      // 이 경우 형식 2가 아니라 형식 1이 되어야 한다.
      // <channel> 요소를 이동해 새로운 루트로 만든다.
      $xml = $xml->channel;
   } // End of if ((is_object($obj1) == false) ...
	
   // 파싱을 위해 XML 유효성을 한번 더 점검한다.
   if ((is_object($xml) == false) || (sizeof($xml) <= 0)) {
      // XML 파싱 오류. 지금 바로 끝낸다.
      return(false);
   } // End of if ((is_object($xml) == false) ...
	
   // 인출한 <item> 요소를 세기 위해 변수를 초기화한다.
   $count_of_rss_items_retrieved = 0;
	
   // <item> 요소에서 세부 사항을 수집하기 위해 루프를 돈다.
   foreach ($xml->item as $item) {
      // 이 단계에서 한번에 <item> 요소 하나에 접근한다.
      // 얼마나 많은 <item> 요소가 있는지 모른다.
      // 제목, 링크, 설명 요소를 읽자.
      $rss_feed_title = trim(strval($item->title));
      $rss_feed_url = trim(strval($item->link));
      $rss_feed_description = trim(strval($item->description));
      // 이 값을 배열 참조에 넣자.
      array_push($rss_feed_title_array, $rss_feed_title);
      array_push($rss_feed_url_array, $rss_feed_url);
      array_push($rss_feed_description_array, $rss_feed_description);
      // 사용자가 원하는 개수를 얻기 위해 읽은 <item> 요소 개수를 증가시킨다.
      $count_of_rss_items_retrieved++;    	
      
      if ($count_of_rss_items_retrieved >= $max_rss_items_required) {
	      // 이제 루프에서 벗어날 때다.
	      break;
      } // End of if ($count_of_rss_items_retrieved >= $max_rss_items_required)   	
   } // End of foreach ($xml->item as $item)
	
   if ($count_of_rss_items_retrieved > 0) {
      // 마지막으로 과실을 딸 시기다.
      return(true);
   } else {
      // 열심히 작업했지만 결실이 없다.
      // 다음 번에는 운이 좋으리라.
      return(false);
   } // End of if ($count_of_rss_items_retrieved > 0)	
} // End of function parse_rss_feed_xml
		

                
function get_list_of_rss_feed_sources($input_xml_file) {
   // 입력 파일에서 XML 내용을 읽어들인다.
   file_exists($input_xml_file) or die("Could not find file " . $input_xml_file);
   $xml_string_contents = file_get_contents($input_xml_file); 
   // 이제 호출자에게 XML 내용을 반환한다.
   return($xml_string_contents);
} // End of function get_list_of_rss_feed_sources
		

                
<?xml version="1.0" encoding="UTF-8"?>
<ListOfRssFeedSources>
   <!-- 피드 제공기 1을 위한 자료 집합이다 -->
   <RssFeedSourceInfo>
      <rssFeedProviderName>Barron's: Markets</rssFeedProviderName>
      <rssFeedProviderUrl>
         http://online.barrons.com/xml/rss/3_7517.xml
      </rssFeedProviderUrl>
      <maximumRssItemsToBeReturned>5</maximumRssItemsToBeReturned>
   </RssFeedSourceInfo>

   <!-- RSS 피드 제공기 항목을 여기 추가한다. -->
</ListOfRssFeedSources>
		

                
function aggregate_rss_feeds($input_xml_file = RSS_FEED_SOURCES_FILE_NAME) {
   // 처리 중인 현재 RSS 피드 소스를 추적하기 위한 변수를 선언한다.
   $feed_source_sequence_number = 0;
   // RSS 피드 소스 목록을 얻는다.
   // 여기서는 입력 파일에서 읽어온다.
   $xml_string_contents = get_list_of_rss_feed_sources($input_xml_file);

   /*
    PHP SimpleXML API를 사용해 XML 형식으로 인코딩된 RSS 피드를 파싱한다.
   */
   // SimpleXML 객체 표현을 얻기 위해 XML 문자열을 올리는 작업부터 시작하자.
   $xml = simplexml_load_string($xml_string_contents);

   // 유효한 XML 문서인가?
   if ($xml == false) {
      print ("Sorry. Your RSS feed sources input file contains invalid data.\n");
      // XML parsing error. Return now.
      return;
   } // End of if ($xml == false)	
	
   print ("\n");
	
   /*
   각 소스에서 RSS 피드를 얻기 위해 루프를 돈다.
   입력 XML 파일의 문서 루트 요소는 <ListOfRssFeedSources>이다.
   루트 요소 아래에서 다음 형식을 따르는 자료 블록이 하나 이상 나온다.

   <RssFeedSourceInfo>
      <rssFeedProviderName>....</rssFeedProviderName>
      <rssFeedProviderUrl>....</rssFeedProviderUrl>
      <maximumRssItemsToBeReturned>....</maximumRssItemsToBeReturned>
   </RssFeedSourceInfo>	

   <RssFeedSourceInfo> 요소를 차례로 순회한다.
   */
   foreach ($xml->RssFeedSourceInfo as $feed_source) {
      // 입력 파일에서 다음 피드 소스에 대한 세부 내역을 읽는다.
      $feed_source_sequence_number++;		
      $rss_provider_name = trim(strval($feed_source->rssFeedProviderName));
      $rss_provider_url = trim(strval($feed_source->rssFeedProviderUrl));
      $max_rss_items_required =
         trim(strval($feed_source->maximumRssItemsToBeReturned));
      print ("Getting RSS feeds from $rss_provider_name ...\n");
		
      // 이제 이 피드 소스에서 RSS 피드를 읽으러 간다.
      $rss_feeds_result_array = 
         get_rss_feeds($rss_provider_name, $rss_provider_url, $max_rss_items_required);
			
      if (empty($rss_feeds_result_array) == false) {
         // 하나 이상 RSS 피드 결과가 있을 때만 저장한다.
         // 결과 배열 형식은 다음에 호출하는 저장 함수에서 설명한다.
         store_rss_feed_results($feed_source_sequence_number, 
            $rss_feeds_result_array);
      } // End of if (empty($rss_feeds_result_array) == false)
   } // End of foreach ($xml->RssFeedSourceInfo as $feed_source)

   print ("\nFinished getting RSS feeds from $feed_source_sequence_number " .
      "feed sources.\n\n");
   print ("You can view the received feed items in the .\feed_results directory.\n\n");
   print ("Feeds from each active feed source are stored in separate files.\n\n");
   print ("These files are named NNN_rss_feed_items.txt, where NNN corresponds to\n" .
      "the sequence number of the order in which the feed source is\n" .
      "listed in your $input_xml_file file.\n");
} // End of function aggregate_rss_feeds
		

                
function store_rss_feed_results($file_sequence_number, $result_array) {
   // "feed_results"라는 하위 디렉터리가 존재하는지 가장 먼저 점검한다.
   if (file_exists(RSS_FEED_RESULTS_DIRECTORY) == false) {
      // 디렉터리가 존재하지 않는다. 지금 생성한다.
      mkdir(RSS_FEED_RESULTS_DIRECTORY);		
   } // End of if (file_exists(RSS_FEED_RESULTS_DIRECTORY) == false)
	
   // 파일 이름을 만든다.
   $result_file_name = sprintf("%s/%03d%s", RSS_FEED_RESULTS_DIRECTORY,
      $file_sequence_number, RSS_FEED_RESULTS_FILE_NAME_SUFFIX);
	
   // 이 파일이 이미 만들어져 있다면 그냥 지워버린다.
   // 최신 피드 자료로 겹쳐쓸 것이다.
   if (file_exists($result_file_name) == true) {
      unlink($result_file_name);
   }

   // 파일을 만들고 연다.
   $handle = fopen($result_file_name, FILE_CREATE_WRITE_FLAG);
	
   if ($handle == false) {
      // 파일 생성에 실패했으므로 바로 끝낸다.
      return;
   } 
	
   // 받은 RSS 피드를 이 파일에 기록하기 시작한다.
   // 피드 제공자 연속 번호를 쓴다.
   $feed_provider_number = FEED_PROVIDER_SEQUENCE_NUMBER . 
      $file_sequence_number . NEW_LINE;
   fwrite($handle, $feed_provider_number);
   // 피드 제공자 이름을 쓴다.
   $feed_provider_name = RSS_FEED_PROVIDER_NAME . $result_array[0] . NEW_LINE;
   fwrite($handle, $feed_provider_name);
   // 받은 피드 항목 개수를 쓴다.
   $number_of_received_rss_feeds = RECEIVED_RSS_FEEDS_CNT . 
      $result_array[1] . NEW_LINE;
   fwrite($handle, $number_of_received_rss_feeds);

   $rss_feed_title_array = $result_array[2];
   $rss_feed_url_array = $result_array[3];
   $rss_feed_description_array = $result_array[4];

   // 루프를 돌면서 제목, URL, 설명을 쓴다.
   for($cnt=0; $cnt < sizeof($rss_feed_title_array); $cnt++) {
      $feed_item_separator = FEED_ITEM_SEPARATOR_LINE . NEW_LINE;
      fwrite($handle, $feed_item_separator);
      $feed_item_sequence_number = FEED_ITEM_SEQUENCE_NUMBER . 
         ($cnt+1) . NEW_LINE;
      fwrite($handle, $feed_item_sequence_number);
      $feed_item_title = FEED_ITEM_TITLE . 
         $rss_feed_title_array[$cnt] . NEW_LINE;
      fwrite($handle, $feed_item_title);
      $feed_item_url = FEED_ITEM_URL .
         $rss_feed_url_array[$cnt] . NEW_LINE;
      fwrite($handle, $feed_item_url);
      $feed_item_description = FEED_ITEM_DESCRIPTION . NEW_LINE .
         $rss_feed_description_array[$cnt] . NEW_LINE;
      fwrite($handle, $feed_item_description);		
   } // End of for($cnt=0; $cnt < sizeof($rss_feed_title_array), $cnt++)

   $feed_item_separator = FEED_ITEM_SEPARATOR_LINE . NEW_LINE;
   fwrite($handle, $feed_item_separator);	
   fclose($handle);
} // End of function store_rss_feed_results
		

                
php -f rss_feed_aggregator.php <피드 소스 입력 XML 파일이름>