Web架构(二)PHP Socket与Java ServerSocket交互

本文主要是介绍Web架构(二)PHP Socket与Java ServerSocket交互，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

Web架构(二)PHP Socket与Java ServerSocket交互

现在流行微服务,SOA服务治理，RPC.都是基于某种协议,进行数据交换.
前边使用php进行数据渲染，调用后端的接口获取数据，前后端分离比较灵活，中间的数据交换协议要统一一致起来。前端不用关心后端是什么语言，只需要通过约定的协议调用接口即可。
本文讲述Java使用服务器端Socket提供服务，PHP使用Socket请求服务端，进行数据交互。

效果：

php页面

这里写图片描述

mysql数据库

这里写图片描述

java控制台

这里写图片描述

代码

Server.java

package cn.pangpython.mybase.rpc;import cn.pangpython.mybase.dbop.MyBatis;
import cn.pangpython.mybase.dbop.User;import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;public class Server {public static void main(String[] args) throws IOException {//创建服务端socket 使用8089端口ServerSocket ss = new ServerSocket(8089);System.out.println("启动服务器....");while (true) {//开启监听Socket s = ss.accept();System.out.println("客户端:" + s.getInetAddress().getLocalHost() + "已连接到服务器");BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));//读取客户端发送来的消息String mess = mess = br.readLine();System.out.println("客户端发送的信息：" + mess);
//            while ((mess = br.readLine())!= null){
//            }//根据传过来的userid去数据库查询user,返回String userId = mess.substring(mess.indexOf("=") + 1);System.out.println("useris:" + userId);MyBatis myBatis = new MyBatis();int uid = Integer.parseInt(userId);User user = myBatis.getUser(uid);//返回数据if (user != null) {BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));bw.write("<h1>User:" + user.toString() + "</h1>\n");bw.flush();bw.close();}br.close();s.close();}}
}

index.php

<!DOCTYPE html>
<html><head><meta charset="utf-8"><title></title></head><body></body>
</html>
<?php
//创建socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_connect($socket, '127.0.0.1', 8089);
//要发送的内容
$send = <<<EOF
userid=1\r\n
EOF;
echo "send data:'userid=1' to server.<br>";
//发送给服务器数据
socket_write($socket, $send, strlen($send));
//接受服务器返回的数据
while($str = socket_read($socket, 1024))
{echo 'receive:<br>';echo $str;
}
socket_close($socket);