likang

Home/Lib/Action/ListeningFileCreateAction.class.php

@@ -16,8 +16,9 @@ class ListeningFileCreateAction extends Action {
 	
  
 	public  function redis_to_kafka(  ){
+		ini_set('memory_limit', '256M');
 		$redis = new redis();
-		$redis->connect('127.0.0.1',6379);
+		$redis->connect('192.168.1.105',6379);
 		$redis->select(1);
 		$result = $redis->ping();
 		echo "redis连接结果=>".$result.PHP_EOL;
@@ -55,7 +56,11 @@ class ListeningFileCreateAction extends Action {
 		    {
 		        echo $item;
 		    }
-		    unlink($res);
+			$res1=str_replace("dat","md5",$res);
+			unlink($res);
+			unlink($res1);
+			 
+			
 		
 		}