后台c 语言为服务器端,前台php与客户端。
1.后台c语言代码:
(1)socket_connect.h
#ifndef SOCKET_CONNECT_H
#define SOCKET_CONNECT_H
#include <sys/types.h>
#include <sys/socket.h>
#include <string.h>
#include <stdio.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
/*
*函数介绍:套接字初始化
*输入参数:socket 套接字文件地址,port 监听端口
*输出参数:socket 套接字文件
*返回值:
*/
void socket_connect_init(int *sockfd,unsigned short port);
/*
*函数介绍:接收信息
*输入参数:client 客户端信息储存地址,msg 接受到的信息,len 表示msg存储空间
*输出参数:client 客户端信息
*返回值:
*/
void socket_connect_recv(int sock,struct sockaddr_in *client,char *msg,int len);
/*
*函数介绍:发送信息
*输入参数:client 客户端信息储存地址,msg 发送的信息,len 表示信息长度
*输出参数:
*返回值:
*/
void socket_connect_send(int sock,struct sockaddr_in *client,char *msg,int len);
/*
*函数介绍:关闭套接字
*输入参数:sock套接字文件描述符
*输出参数:
*返回值:
*/
void socket_connect_close(int sockfd);
#endif
(2)soceket_connect.c
#include "socket_connect.h"
void socket_connect_init(int *sockfd,unsigned short port)
{
int sock;
struct sockaddr_in server;
int structlength;
memset((char *)&server,0,sizeof(server));
server.sin_family = AF_INET;
server.sin_addr.s_addr = htonl(INADDR_ANY);
server.sin_port = htons(port);
if((sock = socket (AF_INET,SOCK_DGRAM,0)) < 0 ){
printf("socket create error!\n");
exit(1);
}
structlength = sizeof(server);
if( bind(sock,(struct sockaddr *) &server,structlength) < 0){
printf("socket bind error!\n");
perror("bind");
exit(1);
}
*sockfd = sock;
}
void socket_connect_recv(int sock,struct sockaddr_in *client,char *msg,int len)
{
memset(client,0,sizeof(struct sockaddr_in));
int structlength = sizeof(struct sockaddr_in);
int recvd = recvfrom(sock,msg,len,0,(struct sockaddr *) client,&structlength);
if(recvd < 0){
perror("recvfrom");
exit(EXIT_FAILURE);
}
else{
msg[recvd] = '\0';
}
}
void socket_connect_send(int sock,struct sockaddr_in *client,char *msg,int len){
int structlength = sizeof(struct sockaddr_in);
int snd = sendto(sock,msg,len,0,(struct sockaddr *) client,structlength);
if(snd < 0){
perror("sendto");
exit(1);
}
}
void socket_connect_close(int sockfd){
close(sockfd);
}
(3)使用socket_connect.h 和 socket_connnet.c 建立服务器
#include <stdio.h>
#include "socket_connect.h"
main(){
//sokcet文件描述符
int sock;
//客户端信息
struct sockaddr_in client;
char msg[200];
//初始化
socket_connect_init(&sock,8000);
while(1)
{
//接受信息
socket_connect_recv(sock,&client,msg,200);
printf("recv:%s\n",msg);
msg[0]='s';
//发送信息
socket_connect_send(sock,&client,msg,1);
}
//关闭服务器
socket_connect_close(sock);
}
2.前台php代码
(1)文件 Message.php
<?php
class Message{
private $server_ip;
private $server_port;
private $sock ;
function __construct($server_ip="192.168.101.201",$server_port=8000)
{
$this -> server_ip = $server_ip;
$this -> server_port = $server_port;
$this -> sock=@socket_create(AF_INET,SOCK_DGRAM,0);
if(!$this -> sock)
{
echo "socket create failure";
}
else echo "start\n";
}
function sendMessage($buf)
{
if(!@socket_sendto($this -> sock,$buf,strlen($buf),0,$this -> server_ip, $this -> server_port))
{
echo "send error\n";
socket_close($this -> sock);
exit();
}
$msg = "";
if(!@socket_recvfrom($this -> sock,$msg,256,0,&$this -> server_ip,&$this -> server_port))
{
echo "recvieve error!";
socket_close($this ->sock);
exit();
}
return $msg;
}
function closeMessage()
{
socket_close($this -> sock);
}
}
?>
(2)使用Message类 建立客户端
<?php
//Message.php 的存放路径
require_once("Message.php");
if(isset($_GET['hidden'])){
$message = $_GET['radio'];
$m = new Message("192.168.101.201",8000);
$msg = $m -> sendMessage($message);
echo $msg;
$m -> closeMessage();
}
?>
<html>
<head>
<meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
<title>socket client </title>
</head>
<body>
<form id="form1" name="form1" method="get" action="test.php">
<input name="radio" type="radio" id="radio" value="start" checked="checked" />
开始: <input name="radio" type="radio" id="radio2" value="stop" />
结束:
<input type="radio" name="radio" id="radio3" value="restart" />
重启:
<label>
<input type="submit" name="button" id="button" value="提交" />
</label>
<input name="hidden" type="hidden" id="hidden" value="hidden" />
</form>
</body>
</html>
分享到:
相关推荐
主要介绍了PHP的Socket通信之UDP通信方法,实例分析了php基于socket实现UDP通信的相关技巧,需要的朋友可以参考下
socket通常叫做‘套接字’,用于描述IP地址和端口,是一个通信链的句柄。应用程序通过套接字向网络发出请求或者应答忘了请求。socket既不是程序,也不是协议,其只是操作系统提供的通信层的一组抽象API
本文实例讲述了php socket通信(tcp/udp)方法。分享给大家供大家参考,具体如下: 注意 1.在socket_bind的时候ip地址不能真回环地址如127.0.0.1 2.server.php后台跑起来的时候nohup php server.php > /var/tmp/a.log ...
对 TCP/IP 、 UDP 、 Socket 编程这些词你不会很陌生吧?随着网络技术的发展,这些词充斥着我们的耳朵。 那什么是TCP/IP、UDP? TCP/IP(Transmission Control Protocol/Internet Protocol)即传输控制协议/网间协议...
通过示例代码分别演示了对应的基于socket通信层的 TCP服务器、UDP服务器及Web服务器,异步及进程处理。
对TCP/IP、UDP、Socket编程这些词你不会很陌生吧?随着网络技术的发展,这些词充斥着我们的耳朵。那么我想问: 1. 什么是TCP/IP、UDP? 2. Socket在哪里呢? 3. Socket是什么呢? 4. 你会使用它们吗? 什么是...
websocket聊天室 swoole-masterSwoole 使 PHP 开发人员可以编写高性能高并发的 TCP、UDP、Unix Socket、HTTP、 WebSocket 等服务,让 PHP 不再局限于 Web 领域。Swoole4 协程的成熟将 PHP 带入了前所未有的时期, 为...
使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP,WebSocket 服务。Swoole 可以广泛应用于互联网、移动通信、企业软件、云计算、网络游戏、物联网(IOT)、车联网、智能家居等领域。 使用 PHP...
使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP,WebSocket 服务。Swoole 可以广泛应用于互联网、移动通信、企业软件、云计算、网络游戏、物联网(IOT)、车联网、智能家居等领域。 使用 PHP...
Swoole是一个面向生产环境的 PHP 异步网络通信引擎,使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP,WebSocket 服务
swoole-4.3.0.tgz是linux安装包,可自行编译安装,官网下载,欢迎使用。Swoole是一个面向生产环境的 PHP 异步网络通信引擎,使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP,WebSocket 服务
使 PHP 开发人员可以编写高性能的异步并发 TCP、UDP、Unix Socket、HTTP,WebSocket 服务。Swoole 可以广泛应用于互联网、移动通信、企业软件、云计算、网络游戏、物联网(IOT)、车联网、智能家居等领域。 使用 PHP...
基于JAVA的UDP服务器模型源代码,内含UDP服务器端模型和UDP客户端模型两个小程序,向JAVA初学者演示UDP C/S结构的原理。 简单聊天软件CS模式 2个目标文件 一个简单的CS模式的聊天软件,用socket实现,比较简单。 ...
基于JAVA的UDP服务器模型源代码,内含UDP服务器端模型和UDP客户端模型两个小程序,向JAVA初学者演示UDP C/S结构的原理。 简单聊天软件CS模式 2个目标文件 一个简单的CS模式的聊天软件,用socket实现,比较简单。 ...
HP-Socket,是一套通用的高性能 TCP/UDP/HTTP 通信框架,包含服务端组件、客户端组件和Agent组件,广泛适用于各种不同应用场景的 TCP/UDP/HTTP 通信系统。 其Server 组件:基于IOCP / EPOLL通信模型,并结合缓存池、...