go http启动应用程序

udpserver

udpserver 是go程序需要启动的程序

#include <iostream>
#include <unistd.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <thread>const int BUFFER_SIZE = 1024;int udpSocket;
struct sockaddr_in udpServerAddr, udpClientAddr;void udpServerThread() {socklen_t udpClientAddrLen = sizeof(udpClientAddr);char buffer[BUFFER_SIZE];while (true) {int n = recvfrom(udpSocket, buffer, BUFFER_SIZE, 0, reinterpret_cast<struct sockaddr*>(&udpClientAddr), &udpClientAddrLen);buffer[n] = '\0';std::cout << "Received from client: " << buffer << std::endl;sendto(udpSocket, buffer, n, 0, reinterpret_cast<struct sockaddr*>(&udpClientAddr), udpClientAddrLen);}
}int main() {// 创建 UDP 套接字udpSocket = socket(AF_INET, SOCK_DGRAM, 0);if (udpSocket < 0) {std::cerr << "Socket creation failed" << std::endl;return -1;}memset(&udpServerAddr, 0, sizeof(udpServerAddr));memset(&udpClientAddr, 0, sizeof(udpClientAddr));// 设置服务器地址信息udpServerAddr.sin_family = AF_INET;udpServerAddr.sin_addr.s_addr = INADDR_ANY;udpServerAddr.sin_port = htons(8081);// 绑定套接字到服务器地址if (bind(udpSocket, reinterpret_cast<const struct sockaddr*>(&udpServerAddr), sizeof(udpServerAddr)) < 0) {std::cerr << "Bind failed" << std::endl;return -1;}std::cout << "UDP server listening on port 8081..." << std::endl;// 启动 UDP 服务器线程std::thread serverThread(udpServerThread);// 主线程可以执行其他任务for (int i = 0; i < 10; ++i) {std::cout << "Main thread doing other task: " << i << std::endl;sleep(1);}// 等待 UDP 服务器线程结束（这里只是为了示例，实际应用中可能不会这样做）serverThread.join();close(udpSocket);return 0;
}

go示例程序

这是个比较简单的例子，启动go 的 http server以后立刻启动udpserver

package mainimport ("fmt""io""log""net/http""os/exec""strings"
)func handleRequest(w http.ResponseWriter, r *http.Request) {if r.URL.Path == "/restartUDP" {restartUDPServer()fmt.Fprintln(w, "UDP server restarted.")} else {fmt.Fprintln(w, "Hello, this is your HTTP server!")}
}func startUDPServer() {cmd := exec.Command("your_udp_server_executable_path")err := cmd.Start()if err!= nil {log.Fatal("Error starting UDP server:", err)}log.Println("UDP server started.")
}func restartUDPServer() {stopUDPServer()startUDPServer()
}func stopUDPServer() {// 根据实际情况确定如何停止 UDP 服务器进程，这里只是一个示例cmd := exec.Command("pkill", "your_udp_server_executable_name")err := cmd.Run()if err!= nil {log.Println("Error stopping UDP server:", err)}
}func main() {startUDPServer()http.HandleFunc("/", handleRequest)log.Println("Starting HTTP server on port 8080...")err := http.ListenAndServe(":8080", nil)if err!= nil {log.Fatal("Error starting HTTP server:", err)}
}

改进

改进上面的程序，启动以后发送udp给udpserver，这个代码在接收到/restartUDP的 HTTP 请求时，会重新启动 UDP 服务器，并发送一个测试消息给 UDP 服务器等待响应来确认启动成功。

package mainimport ("bufio""fmt""io""log""net""net/http""os/exec""sync""time"
)var udpConn net.Conn
var mutex sync.Mutexfunc handleRequest(w http.ResponseWriter, r *http.Request) {if r.URL.Path == "/restartUDP" {restartUDPServer()if waitForUDPServerResponse() {fmt.Fprintln(w, "UDP server restarted and response received.")} else {fmt.Fprintln(w, "UDP server restarted but no response received.")}} else {fmt.Fprintln(w, "Hello, this is your HTTP server!")}
}func startUDPServer() {cmd := exec.Command("your_udp_server_executable_path")err := cmd.Start()if err!= nil {log.Fatal("Error starting UDP server:", err)}log.Println("UDP server started.")var err errorudpConn, err = net.Dial("udp", "127.0.0.1:your_udp_port")if err!= nil {log.Fatal("Error connecting to UDP server:", err)}
}func restartUDPServer() {stopUDPServer()startUDPServer()
}func stopUDPServer() {mutex.Lock()if udpConn!= nil {err := udpConn.Close()if err!= nil {log.Println("Error stopping UDP server:", err)}udpConn = nil}mutex.Unlock()
}func waitForUDPServerResponse() bool {// 设置超时时间timeout := time.After(5 * time.Second)// 发送测试消息_, err := udpConn.Write([]byte("test"))if err!= nil {log.Println("Error sending UDP message:", err)return false}// 等待响应for {select {case <-timeout:return falsedefault:message, err := bufio.NewReader(udpConn).ReadString('\n')if err == nil && strings.TrimSpace(message)!= "" {return true}time.Sleep(100 * time.Millisecond)}}
}func main() {startUDPServer()http.HandleFunc("/", handleRequest)log.Println("Starting HTTP server on port 8080...")err := http.ListenAndServe(":8080", nil)if err!= nil {log.Fatal("Error starting HTTP server:", err)}
}