php socket

PHP中文网
リリース: 2016-05-23 08:39:00
オリジナル
1464 人が閲覧しました

1.

1,'c'=>3,'b'=>8);
$json = json_encode($s);
$f = $json."\n";
socket_write($socket,$f,strlen($f));
$string = "";
$buf = "";
while ($int = socket_recv($socket, $buf, 1204,MSG_WAITALL)){
	$string .= $buf;
}
$arr = json_decode($string,true);
print_r($arr);
ログイン後にコピー

2.

package main

import (
	"bufio"
	"encoding/json"
	"fmt"
	"net"
	"os"
)

type Server struct {
	ServerName string
	ServerIp   string
}
type Serverslice struct {
	Servers []Server
}

func main() {
	service := ":4444"
	tcpAddr, err := net.ResolveTCPAddr("tcp4", service)
	checkError(err)
	listener, err := net.ListenTCP("tcp", tcpAddr)
	checkError(err)
	fmt.Println("======>")
	fmt.Println("启动侦听程序")
	for {
		conn, err := listener.Accept()
		if err != nil {
			continue
		}
		fmt.Println("=========>")
		fmt.Println("侦听成功")
		go handleClient(conn)
	}
}

func handleClient(conn net.Conn) {
	defer conn.Close()
	var jsonStr Serverslice
	jsonStr.Servers = append(jsonStr.Servers, Server{ServerName: "nc", ServerIp: "127.0.0.1"})
	jsonStr.Servers = append(jsonStr.Servers, Server{ServerName: "sh", ServerIp: "127.0.0.2"})
	jsonStr.Servers = append(jsonStr.Servers, Server{ServerName: "hn", ServerIp: "127.0.0.3"})
	b, err := json.Marshal(jsonStr)
	if err != nil {
		fmt.Println("json err:", err)
	}
	a, _ := bufio.NewReader(conn).ReadString('\n')
	fmt.Println(string(a))
	conn.Write([]byte(b))
	fmt.Println(string(b))
}

func checkError(err error) {
	if err != nil {
		fmt.Fprintf(os.Stderr, "Fatal error: %s", err.Error())
		os.Exit(1)
	}
}
ログイン後にコピー

           

       

関連ラベル:
ソース:php.cn
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
最新の問題
人気のおすすめ
人気のチュートリアル
詳細>
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート