PHP. Асинхронный скрипт.

[lexasub]

Решил написать скриптик, который с помощью vkapi ищет друзей у моих друзей и выдает мне список "друзей друзей" без моих друзей. Надеюсь что поняли эту тавтологию. Все работает медленно и я решил сделать некоторую часть кода асинхронной:

(Нажмите, чтобы показать/скрыть)

<?
ini_set('max_execution_time', 90000);

/*class workerThread extends Thread {

public function __construct($i){

  $this->i=$i;

}

public function run(){

  while(true){

   echo "Worker {$this->i} ran" . PHP_EOL;

   sleep(1);

  }

}
}*/

/*
$workers[$i]=new workerThread($i);
$workers[$i]->start();
*/
class second_while extends Thread {

public $l="";

public function __construct($i,&$friends,&$i,&$u,&$res){//$friends $i $u $res

  $this->i=$i;

  $this->l=array('f'=>&$friends,'i'=>&$i,'u'=>&$u,'res'=>&$res);

}

public function run(){

  while(true){

   

$tmp=get_friends($this->l['f'][$this->l['i']]);//$friends $i $u $res

$j=0;

while(isset($tmp[$j]))

{

if(!(($tmp[$j]==$this->l['u']or(in_array($tmp[$j],$this->l['f']))))

{

if(isset($this->l['res'][$tmp[$j]]))

{

$this->l['res'][$tmp[$j]]++;

}

else

{

$this->l['res'][$tmp[$j]]=1;

}

}

$j++;

}

}
}

function get_friends($u_id)
{

return json_decode(file_get_contents('https://api.vk.com/method/friends.get?user_id='.$u_id))->response;
}    
function get_users_info(&$ids) {

$params = array('http'=>array('method'=>'POST','header'=>'Content-type: application/x-www-form-urlencoded','content'=>http_build_query(array(//

'user_ids'=> implode(",",array_keys($ids)),

'fields'=>'photo_100',

'v'=>'5.62'

))

));

return json_decode(file_get_contents("https://api.vk.com/method/users.get", false, stream_context_create($params)))->response;
} 

function info(&$ids)
{

global $u;

$tmp=get_users_info($ids);

$str="";

foreach($tmp as $v)

{

$str.=$v->id." ".$v->first_namea." ".$v->last_name."<img src='".$v->photo_100."'>".":".$ids[$v->id]."</br>";

}

return $str;

}

$u = $_GET["a"];
if(($u!='')&&isset($_GET["a"])){
    
    $friends=get_friends($u);

$i=0;

$res=array();

$sec_whl="";

while(isset($friends[$i]))
    {

/*$tmp=get_friends($friends[$i]);

$j=0;

while(isset($tmp[$j]))

{

$a=$tmp[$j];

if(!(($a==$u)or(in_array($a,$friends))))

{

if(isset($res[$a]))

{

$res[$a]++;

}

else

{

$res[$a]=1;

}

}

$j++;

}*/

$sec_whl[$i]=new second_while($i,$friends,$i,$u,$res);//$friends $i $u $res

$sec_whl[$i]->start();

$i++;

}

//сдесь я хочу ждать завершение потоков из массива sec_whl

arsort($res);//asort() ïî âîçðàñòàíèþ, à ïî óáûâàíèþ arsort()

$res=array_chunk($res, 1000, TRUE);

foreach($res as $v)

{

echo info($v);

}
}
?>

 
Пользователь добавил сообщение 11 Февраля 2017, 15:23:53:и я не понимаю, как мне ждать потоки

[alsoijw]

lexasub, 1) вставляй код с помощью тега [​code] (набери сам а не копипасть) 2) не смешивай разные кодировки 3) как насчёт того чтоб взять язык в котором многопоточность из коробки, например golang, а не php?

[lexasub]

lexasub, 1) вставляй код с помощью тега [​code] (набери сам а не копипасть) 2) не смешивай разные кодировки 3) как насчёт того чтоб взять язык в котором многопоточность из коробки, например golang, а не php?

1 - я с помощью тега [php] вставлял код
2- кодировки - знаю
3- go не знаю (можно на perl,но php я гораздо лучше знаю)

[alsoijw]

lexasub, 1) я имею в виду на форум
3) golang достаточно прост. http://golang-book.ru/chapter-10-concurrency.html

[lexasub]

1)я написал "" [php*][*/php]
3)go я начал вчера изучать
Но у меня не получилось переписать код
Пользователь добавил сообщение 12 Февраля 2017, 10:11:32:Кто-нибудь перепишите код с php на go(в Go я чайник).
Пользователь добавил сообщение 12 Февраля 2017, 14:43:26:Накидал код с ошибками:

(Нажмите, чтобы показать/скрыть)

http.go:

Код: [Выделить]

package http

import (
        "net/http"
        "io/ioutil"
        "encoding/json"
        "strings"
       )
func array_keys(mymap *map[int64]int64)[]string{
    keys := make([]string, 0, len(mymap))
    for k := range mymap {
        keys = append(keys, string(k))
    }
    return keys
}

func get_content(tmp string)[]byte{
    response,err := http.Get(tmp);
    if err == nil {
        //
    }
    contents, err := ioutil.ReadAll(response.Body)
    if err == nil {
        //
    }
    return contents
}
func info(ids *map[int64]int64)string{
    params:="?user_ids="+strings.Join(array_keys(ids),",")+"&fields=photo_100&v=5.62"//array_keys to go
    type User struct {
        response struct{
            id  int64
            first_name string
            last_name string
            photo_100 string
        }
    }
    var users User
    json.Unmarshal(get_content("https://api.vk.com/method/users.get"+params),&users)
    tmp:=users.response
    var str string;
    for _, v := range tmp {
        str+=v.id+" "+v.first_name+" "+v.last_name+"<img src='"+v.photo_100+"'>"+":"+ids[v.id]+"</br>";
    }
    return str;
}

func get_friends(id *int64)[]int64{
    type Friend struct {
        response struct{
            count  int64
            items []int64
        }
    }
    var friends Friend
    json.Unmarshal(get_content("https://api.vk.com/method/friends.get?user_id="+string(id)),&friends)
    return friends.response.items
   
}
   
    //fmt.Printf("%+v", animals)

выдает

(Нажмите, чтобы показать/скрыть)

# goland-book/vkfriends/http
/usr/lib/go-1.6/src/goland-book/vkfriends/http/http.go:10: invalid argument mymap (type *map[int64]int64) for len
/usr/lib/go-1.6/src/goland-book/vkfriends/http/http.go:11: cannot range over mymap (type *map[int64]int64)
/usr/lib/go-1.6/src/goland-book/vkfriends/http/http.go:42: cannot range over tmp (type struct { id int64; first_name string; last_name string; photo_100 string })
/usr/lib/go-1.6/src/goland-book/vkfriends/http/http.go:56: cannot convert id (type *int64) to type string

Что мне делать?
Пользователь добавил сообщение 12 Февраля 2017, 14:48:31:Есть еще файл main.go, но я его не могу дебажить, т.к http.go является пакетом с ошибками
многопоточность еще не накладовал

[alsoijw]

lexasub, 1) указатели надо разыменовывать. http://golang-book.ru/chapter-08-pointers.html Напиши "*" перед именем указателя. 2) для того чтобы пройтись по элементам словаря(он же map) нужно две переменных: ключ и значение. Посмотри тут http://golang-book.ru/chapter-06-arrays-slices-maps.html 3) что ты пытаешься сделать со структурой? 4) для преобразование числа в строку есть itoa (int to ascii) http://stackoverflow.com/questions/10105935/how-to-convert-an-int-value-to-string-in-go. Не забывай разыменовывать указатели.
Пользователь добавил сообщение 12 Февраля 2017, 20:44:27:И зачем в последней функции указатель?

[Komorebi]

Многопоточность и асинхрон - вещи разные.
В пхп нету асинхрона.

[lexasub]

не все сделал(не все понял)

(Нажмите, чтобы показать/скрыть)

Код: [Выделить]

package http

import (
        "net/http"
        "io/ioutil"
        "encoding/json"
        "strings"
       )
func array_keys(mymap *map[int64]int64)[]string{
    keys := make([]string, 0, len(*mymap))
    for k := range *mymap {
        keys = append(keys, string(k))
    }
    return keys
}

func get_content(tmp string)[]byte{
    response,err := http.Get(tmp);
    if err == nil {
        //
    }
    contents, err := ioutil.ReadAll(response.Body)
    if err == nil {
        //
    }
    return contents
}
func info(ids *map[int64]int64)string{
    params:="?user_ids="+strings.Join(array_keys(&*ids),",")+"&fields=photo_100&v=5.62"//array_keys to go
    type User struct {
        response struct{
            id  int64
            first_name string
            last_name string
            photo_100 string
        }
    }
    var users User
    json.Unmarshal(get_content("https://api.vk.com/method/users.get"+params),&users)
    tmp:=users.response
    var str string;
    for _, v := range tmp {
        str+=v.id+" "+v.first_name+" "+v.last_name+"<img src='"+v.photo_100+"'>"+":"+ids[v.id]+"</br>";
    }
    return str;
}

func get_friends(id *int64)[]int64{
    type Friend struct {
        response struct{
            count  int64
            items []int64
        }
    }
    var friends Friend
    json.Unmarshal(get_content("https://api.vk.com/method/friends.get?user_id="+Itoa(*id)),&friends)
    return friends.response.items
   
}

[alsoijw]

lexasub, ошибки остались? Я не против подсказать если знаю, но самому искать ошибки лень.

[lexasub]

скину
Пользователь добавил сообщение 14 Февраля 2017, 11:56:26:43: cannot range over tmp (type struct { id int64; first_name string; last_name string; photo_100 string })
/usr/lib/go-1.6/src/goland-book/vkfriends/http/http.go:57: cannot use *id (type int64) as type int in argument to strconv.Itoa

Пользователь добавил сообщение 14 Февраля 2017, 15:28:30:

lexasub, ошибки остались? Я не против подсказать если знаю, но самому искать ошибки лень.

43: cannot range over tmp (type struct { id int64; first_name string; last_name string; photo_100 string })
/usr/lib/go-1.6/src/goland-book/vkfriends/http/http.go:57: cannot use *id (type int64) as type int in argument to strconv.Itoa

[alsoijw]

lexasub, для того чтобы обратится к полям структуры не нужно писать range. просто напиши имя переменной структуры, точка, имя поля. Не понятно действие в 43 строке - если переменная str ничего не содержит, то зачем писать += ? По поводу второй ошибки http://stackoverflow.com/questions/12219911/strconv-itoa641234-gives-undefined-in-golang

[lexasub]

Пользователь добавил сообщение 14 Февраля 2017, 16:29:39:

lexasub, для того чтобы обратится к полям структуры не нужно писать range. просто напиши имя переменной структуры, точка, имя поля. Не понятно действие в 43 строке - если переменная str ничего не содержит, то зачем писать += ? По поводу второй ошибки http://stackoverflow.com/questions/12219911/strconv-itoa641234-gives-undefined-in-golang

(Нажмите, чтобы показать/скрыть)

Код: [Выделить]

package http

import (
        "net/http"
        "io/ioutil"
        "encoding/json"
        "strings"
        "strconv"
       )
func array_keys(mymap *map[int64]int64)[]string{
    keys := make([]string, 0, len(*mymap))
    for k := *mymap {//я не понял, как перебирать карту
        keys = append(keys, string(k))
    }
    return keys
}

func get_content(tmp string)[]byte{
    response,err := http.Get(tmp);
    if err == nil {
        //
    }
    contents, err := ioutil.ReadAll(response.Body)
    if err == nil {
        //
    }
    return contents
}
func info(ids *map[int64]int64)string{
    params:="?user_ids="+strings.Join(array_keys(&*ids),",")+"&fields=photo_100&v=5.62"//array_keys to go
    type User struct {
        response struct{
            id  int64
            first_name string
            last_name string
            photo_100 string
        }
    }
    var users User
    json.Unmarshal(get_content("https://api.vk.com/method/users.get"+params),&users)
    tmp:=users.response
    var str string;
    for _, v := range tmp {//cannot range over tmp (type struct { id int64; first_name string; last_name string; photo_100 string })

        str+=v.id+" "+v.first_name+" "+v.last_name+"<img src='"+v.photo_100+"'>"+":"+ids[v.id]+"</br>";
    }
    return str;
}

func get_friends(id *int64)[]int64{
    type Friend struct {
        response struct{
            count  int64
            items []int64
        }
    }
    var friends Friend
    json.Unmarshal(get_content("https://api.vk.com/method/friends.get?user_id="+strconv.FormatInt(*id,10)),&friends)
    return friends.response.items
   
}
   
    //fmt.Printf("%+v", animals)р

[alsoijw]

lexasub, map перебираешь с помощью range, как в предыдущем варианте.

Код: [Выделить]

for k := range *mymap {в случае со структурой выглядеть будет как-то так

Код: [Выделить]

return users.response.id+" "+users.response.first_name+" "+users.response.last_name+"<img src='"+users.response.photo_100+"'>"+":"+ids[users.response.id]+"</br>"Прочитай и выполни все уроки в руководстве о котором я писал выше.

[lexasub]

return users.response.id+" "+users.response.first_name+" "+users.response.last_name+"<img src='"+users.response.photo_100+"'>"+":"+ids[users.response.id]+"</br>"

вы неправильно наверно меня поняли. Вот что выдает сервер:
{
"response": [{
  "id": 210700286,
  "first_name": "Lindsey",
  "last_name": "Stirling",
  "photo_100": "https://pp.vk.me/...a74/eS6d5nIw-Os.jpg"
}, {
  "id": 1,
  "first_name": "Pavel",
  "last_name": "Durov",
  "photo_100": "https://pp.vk.me/...542/fcMCbfjDsv0.jpg"
}]
}
и мне надо перебирать пользователей и выводить строку для каждого пользователя

[alsoijw]

lexasub, я понял код а не то что ты пытаешься делать. Если у тебя несколько пользователей, то тогда объяви массив пользователей. У тебя в данный момент users это просто переменная(емнип в перле их называют скаляром). https://gobyexample.com/json http://stackoverflow.com/questions/25465566/golang-parse-json-array-into-data-structure