pc 机和android 手机之间的通信

红太狼 2022-08-08 03:19 152阅读 0赞

客户端：

package com.android.settings;  
  
import java.io.IOException;  
import java.io.PrintStream;  
import java.net.Socket;  
import java.net.UnknownHostException;  
  
import android.app.Activity;  
import android.os.Bundle;  
import android.os.Handler;  
import android.os.Message;  
import android.view.View;  
import android.widget.Button;  
import android.widget.EditText;  
import android.widget.Toast;  
  
public class BogoclientActivity extends Activity \{  
/\* 服务器地址 \*/  
private final String SERVER\_HOST\_IP = "10.0.0.158";  
  
/\* 服务器端口 \*/  
private final int SERVER\_HOST\_PORT = 9400;  
  
private Button btnConnect;  
private Button btnSend;  
private EditText editSend;  
private Socket socket;  
private PrintStream output;  
  
public void toastText(String message) \{  
Toast.makeText(this, message, Toast.LENGTH\_LONG).show();  
\}  
  
public void handleException(Exception e, String prefix) \{  
e.printStackTrace();  
//toastText(prefix + e.toString());  
\}  
  
/\*\* Called when the activity is first created. \*/  
@Override  
public void onCreate(Bundle savedInstanceState) \{  
super.onCreate(savedInstanceState);  
setContentView(R.xml.client\_socket\_layout);  
  
initView();  
  
btnConnect.setOnClickListener(new Button.OnClickListener() \{  
@Override  
public void onClick(View v) \{  
  
client client = new client();  
new Thread(client).start();  
\}  
\});  
  
btnSend.setOnClickListener(new Button.OnClickListener() \{  
@Override  
public void onClick(View v) \{  
sendMessage(editSend.getText().toString());  
\}  
\});  
\}  
  
public void initView() \{  
btnConnect = (Button) findViewById(R.id.btnConnect);  
btnConnect.setText("connect");  
btnSend = (Button) findViewById(R.id.btnSend);  
btnSend.setText("send");  
editSend = (EditText) findViewById(R.id.sendMsg);  
editSend.setText("editSend");  
  
btnSend.setEnabled(false);  
editSend.setEnabled(false);  
\}  
  
public void closeSocket() \{  
try \{  
output.close();  
socket.close();  
\} catch (IOException e) \{  
handleException(e, "close exception: ");  
\}  
\}  
  
private void initClientSocket() \{  
try \{  
/\* 连接服务器 \*/  
socket = new Socket(SERVER\_HOST\_IP, SERVER\_HOST\_PORT);  
  
/\* 获取输出流 \*/  
output = new PrintStream(socket.getOutputStream(), true, "utf-8");  
Message message = mHandler.obtainMessage();  
message.arg1 =1;  
mHandler.sendMessage(message);  
  
\} catch (UnknownHostException e) \{  
handleException(e, "unknown host exception: " + e.toString());  
\} catch (IOException e) \{  
handleException(e, "io exception: " + e.toString());  
\}  
\}  
  
private void sendMessage(String msg) \{  
output.print(msg);  
\}  
  
  
  
class client implements Runnable\{  
  
@Override  
public void run() \{  
// TODO Auto-generated method stub  
initClientSocket();  
\}  
  
\}  
  
final Handler mHandler = new Handler()\{  
@Override  
public void handleMessage(Message msg) \{  
// TODO Auto-generated method stub  
super.handleMessage(msg);  
  
btnConnect.setEnabled(false);  
editSend.setEnabled(true);  
btnSend.setEnabled(true);  
\}  
\};  
\}

服务器端package com.android.settings;  
  
import java.io.IOException;  
import java.io.PrintStream;  
import java.net.Socket;  
import java.net.UnknownHostException;  
  
import android.app.Activity;  
import android.os.Bundle;  
import android.os.Handler;  
import android.os.Message;  
import android.view.View;  
import android.widget.Button;  
import android.widget.EditText;  
import android.widget.Toast;  
  
public class BogoclientActivity extends Activity \{  
/\* 服务器地址 \*/  
private final String SERVER\_HOST\_IP = "10.0.0.158";  
  
/\* 服务器端口 \*/  
private final int SERVER\_HOST\_PORT = 9400;  
  
private Button btnConnect;  
private Button btnSend;  
private EditText editSend;  
private Socket socket;  
private PrintStream output;  
  
public void toastText(String message) \{  
Toast.makeText(this, message, Toast.LENGTH\_LONG).show();  
\}  
  
public void handleException(Exception e, String prefix) \{  
e.printStackTrace();  
//toastText(prefix + e.toString());  
\}  
  
/\*\* Called when the activity is first created. \*/  
@Override  
public void onCreate(Bundle savedInstanceState) \{  
super.onCreate(savedInstanceState);  
setContentView(R.xml.client\_socket\_layout);  
  
initView();  
  
btnConnect.setOnClickListener(new Button.OnClickListener() \{  
@Override  
public void onClick(View v) \{  
  
client client = new client();  
new Thread(client).start();  
\}  
\});  
  
btnSend.setOnClickListener(new Button.OnClickListener() \{  
@Override  
public void onClick(View v) \{  
sendMessage(editSend.getText().toString());  
\}  
\});  
\}  
  
public void initView() \{  
btnConnect = (Button) findViewById(R.id.btnConnect);  
btnConnect.setText("connect");  
btnSend = (Button) findViewById(R.id.btnSend);  
btnSend.setText("send");  
editSend = (EditText) findViewById(R.id.sendMsg);  
editSend.setText("editSend");  
  
btnSend.setEnabled(false);  
editSend.setEnabled(false);  
\}  
  
public void closeSocket() \{  
try \{  
output.close();  
socket.close();  
\} catch (IOException e) \{  
handleException(e, "close exception: ");  
\}  
\}  
  
private void initClientSocket() \{  
try \{  
/\* 连接服务器 \*/  
socket = new Socket(SERVER\_HOST\_IP, SERVER\_HOST\_PORT);  
  
/\* 获取输出流 \*/  
output = new PrintStream(socket.getOutputStream(), true, "utf-8");  
Message message = mHandler.obtainMessage();  
message.arg1 =1;  
mHandler.sendMessage(message);  
  
\} catch (UnknownHostException e) \{  
handleException(e, "unknown host exception: " + e.toString());  
\} catch (IOException e) \{  
handleException(e, "io exception: " + e.toString());  
\}  
\}  
  
private void sendMessage(String msg) \{  
output.print(msg);  
\}  
  
  
  
class client implements Runnable\{  
  
@Override  
public void run() \{  
// TODO Auto-generated method stub  
initClientSocket();  
\}  
  
\}  
  
final Handler mHandler = new Handler()\{  
@Override  
public void handleMessage(Message msg) \{  
// TODO Auto-generated method stub  
super.handleMessage(msg);  
  
btnConnect.setEnabled(false);  
editSend.setEnabled(true);  
btnSend.setEnabled(true);  
\}  
\};  
\}

服务器端：

\#include <sys/types.h>  
\#include <sys/socket.h>  
\#include <netinet/in.h>  
\#include <arpa/inet.h>  
\#include <unistd.h>  
\#include <stdlib.h>  
\#include <stdio.h>  
  
\#define PORT 9400  
\#define MAX\_BUFFER 1024  
  
  
int main()  
\{  
/\* create a socket \*/  
int server\_sockfd = socket(AF\_INET, SOCK\_STREAM, 0);  
  
struct sockaddr\_in server\_addr;  
server\_addr.sin\_family = AF\_INET;  
server\_addr.sin\_addr.s\_addr = inet\_addr("10.0.0.158");  
server\_addr.sin\_port = htons(PORT);  
  
/\* bind with the local file \*/  
bind(server\_sockfd, (struct sockaddr \*)&server\_addr, sizeof(server\_addr));  
  
/\* listen \*/  
listen(server\_sockfd, 5);  
  
int size;  
char buffer\[MAX\_BUFFER + 1\];  
int client\_sockfd;  
struct sockaddr\_in client\_addr;  
socklen\_t len = sizeof(client\_addr);  
  
/\* accept a connection \*/  
printf("waiting connection...\\n");  
client\_sockfd = accept(server\_sockfd, (struct sockaddr \*)&client\_addr, &len);  
printf("connection established!\\n");  
  
while(1)  
\{  
printf("waiting message...\\n");  
  
/\* exchange data \*/  
size = read(client\_sockfd, buffer, MAX\_BUFFER);  
buffer\[size\] = '\\0';  
printf("Got %d bytes: %s\\n", size, buffer);  
\}  
  
/\* close the socket \*/  
close(client\_sockfd);  
  
return 0;  
\}